PatternTopic fixed

redisson · Jun 14, 2017 · 273cff0 · 273cff0
1 parent 012d2e7
commit 273cff0
Showing 1 changed file with 5 additions and 1 deletion.
diff --git 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 @@ protected void decodeResult(CommandData<Object, Object> data, List<Object> parts
             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() {