diff --git a/src/main/java/it/tdlight/reactiveapi/ReactiveApiPublisher.java b/src/main/java/it/tdlight/reactiveapi/ReactiveApiPublisher.java index aa9e66f..aa698d3 100644 --- a/src/main/java/it/tdlight/reactiveapi/ReactiveApiPublisher.java +++ b/src/main/java/it/tdlight/reactiveapi/ReactiveApiPublisher.java @@ -224,7 +224,7 @@ public abstract class ReactiveApiPublisher { // Buffer requests to avoid halting the event loop .doOnNext(clientBoundEvent -> clientBoundEvents.increment()) .transform(ReactorUtils.onBackpressureBufferSubscribe(Paths.get(""), - "client-bound-resulting-events", + "client-bound-resulting-events-" + userId, false, new ClientBoundEventSerializer(), new ClientBoundEventDeserializer()