@ -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
@ -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();
@Override