PubSubConnectionEntry.addListener sync fixed

src/main/java/org/redisson/connection/PubSubConnectionEntry.java

@@ -76,13 +76,18 @@ public class PubSubConnectionEntry {
             }
         }
 
+        boolean deleted = false;
         synchronized (queue) {
             if (channelListeners.get(channelName) != queue) {
+                deleted = true;
+            } else {
+                queue.add(listener);
+            }
+        }
+        if (deleted) {
             addListener(channelName, listener);
             return;
         }
-            queue.add(listener);
-        }
 
         conn.addListener(listener);
     }