From e5712361e02f0ac3ce8a255dec03b9b5307d655c Mon Sep 17 00:00:00 2001 From: Andrea Cavalli Date: Mon, 31 Oct 2022 14:06:25 +0100 Subject: [PATCH] fix --- src/main/java/it/tdlight/reactiveapi/ReactiveApiPublisher.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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()