From e195642a45a69dc2df2b013d656978ac77f186f0 Mon Sep 17 00:00:00 2001
From: Nikita <abracham.mitchell@gmail.com>
Date: Mon, 28 Dec 2015 14:05:18 +0300
Subject: [PATCH] Topic listeners should return identity hash code

---
 src/main/java/org/redisson/RedissonPatternTopic.java | 2 +-
 src/main/java/org/redisson/RedissonTopic.java        | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/main/java/org/redisson/RedissonPatternTopic.java b/src/main/java/org/redisson/RedissonPatternTopic.java
index dbdada5f3..abeb806e2 100644
--- a/src/main/java/org/redisson/RedissonPatternTopic.java
+++ b/src/main/java/org/redisson/RedissonPatternTopic.java
@@ -69,7 +69,7 @@ public class RedissonPatternTopic<M> implements RPatternTopic<M> {
         synchronized (entry) {
             if (entry.isActive()) {
                 entry.addListener(name, pubSubListener);
-                return pubSubListener.hashCode();
+                return System.identityHashCode(pubSubListener);
             }
         }
         // entry is inactive trying add again
diff --git a/src/main/java/org/redisson/RedissonTopic.java b/src/main/java/org/redisson/RedissonTopic.java
index 28f7a1ba9..ca43934c1 100644
--- a/src/main/java/org/redisson/RedissonTopic.java
+++ b/src/main/java/org/redisson/RedissonTopic.java
@@ -80,7 +80,7 @@ public class RedissonTopic<M> implements RTopic<M> {
     private int addListener(RedisPubSubListener<M> pubSubListener) {
         Future<PubSubConnectionEntry> future = commandExecutor.getConnectionManager().subscribe(codec, name, pubSubListener);
         future.syncUninterruptibly();
-        return pubSubListener.hashCode();
+        return System.identityHashCode(pubSubListener);
     }
 
     @Override