Rewritten changes has back. #17

src/main/java/org/redisson/RedissonTopic.java

@@ -69,9 +69,11 @@ public class RedissonTopic<M> extends RedissonObject implements RTopic<M> {
         RedisPubSubAdapter<String, M> listener = new RedisPubSubAdapter<String, M>() {
             @Override
             public void subscribed(String channel, long count) {
-                if (channel.equals(getName())) {
+                Promise<Boolean> subscribePromise = promise.get();
+                //in case of reconnecting, promise might already be completed.
+                if (channel.equals(getName()) && !subscribePromise.isDone()) {
                     log.debug("subscribed to '{}' channel", getName());
-                    newPromise.setSuccess(true);
+                    subscribePromise.setSuccess(true);
                 }
             }
         };