refactoring

redisson/src/main/java/org/redisson/RedissonGeo.java

@@ -92,7 +92,7 @@ public class RedissonGeo<V> extends RedissonScoredSortedSet<V> implements RGeo<V
             params.add(entry.getLatitude());
             params.add(encode(entry.getMember()));
         }
-        return commandExecutor.writeAsync(getName(), StringCodec.INSTANCE, RedisCommands.GEOADD_ENTRIES, params.toArray());
+        return commandExecutor.writeAsync(getName(), StringCodec.INSTANCE, RedisCommands.GEOADD, params.toArray());
     }
 
     @Override

redisson/src/main/java/org/redisson/pubsub/PublishSubscribeService.java

@@ -109,7 +109,7 @@ public class PublishSubscribeService {
                     @Override
                     public void operationComplete(Future<PubSubConnectionEntry> future) throws Exception {
                         if (!future.isSuccess()) {
-                            subscribe(type, codec, channelName, promise, listeners);
+                            promise.tryFailure(future.cause());
                             return;
                         }