PatternTopic fixed

8 years ago · 273cff0d17
parent 012d2e7fbb
commit 273cff0d17
1 changed files with 5 additions and 1 deletions
--- a/redisson/src/main/java/org/redisson/client/handler/CommandPubSubDecoder.java
+++ b/redisson/src/main/java/org/redisson/client/handler/CommandPubSubDecoder.java
@ -86,7 +86,11 @@ public class CommandPubSubDecoder extends CommandDecoder {
            final RedisPubSubConnection pubSubConnection = RedisPubSubConnection.getFrom(channel);
            
            if (keepOrder) {
-                PubSubEntry item = entries.get(((Message) result).getChannel());
+                String ch = ((Message) result).getChannel();
+                if (result instanceof PubSubPatternMessage) {
+                    ch = ((PubSubPatternMessage)result).getPattern();
+                }
+                PubSubEntry item = entries.get(ch);
                enqueueMessage(result, pubSubConnection, item);
            } else {
                executor.execute(new Runnable() {