From 239d5b9c8a189b03fbd4dbe541b64b4ecbc538d6 Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Fri, 23 Jun 2023 11:36:38 +0300 Subject: [PATCH] Fixed - keepPubSubOrder setting isn't used #5123 --- .../org/redisson/client/handler/CommandPubSubDecoder.java | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/redisson/src/main/java/org/redisson/client/handler/CommandPubSubDecoder.java b/redisson/src/main/java/org/redisson/client/handler/CommandPubSubDecoder.java index fad6e9496..f8c734200 100644 --- a/redisson/src/main/java/org/redisson/client/handler/CommandPubSubDecoder.java +++ b/redisson/src/main/java/org/redisson/client/handler/CommandPubSubDecoder.java @@ -154,14 +154,13 @@ public class CommandPubSubDecoder extends CommandDecoder { channelName = ((PubSubPatternMessage) result).getPattern(); } PubSubEntry entry = entries.remove(channelName); - if (config.isKeepAlive()) { + if (config.isKeepPubSubOrder()) { enqueueMessage(result, pubSubConnection, entry); } } } - - - if (config.isKeepAlive()) { + + if (config.isKeepPubSubOrder()) { if (result instanceof PubSubPatternMessage) { channelName = ((PubSubPatternMessage) result).getPattern(); }