NPE fixed. #199

src/main/java/org/redisson/client/handler/CommandDecoder.java

@@ -164,7 +164,7 @@ public class CommandDecoder extends ReplayingDecoder<State> {
                 int slot = Integer.valueOf(errorParts[2]);
                 data.getPromise().setFailure(new RedisMovedException(slot));
             } else {
-                data.getPromise().setFailure(new RedisException(error));
+                data.getPromise().setFailure(new RedisException(error + ". channel: " + channel));
             }
         } else if (code == ':') {
             String status = in.readBytes(in.bytesBefore((byte) '\r')).toString(CharsetUtil.UTF_8);

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

@@ -54,6 +54,7 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager {
         init(config);
 
         this.config = create(cfg);
+        init(this.config);
 
         for (URI addr : cfg.getNodeAddresses()) {
             RedisClient client = createClient(addr.getHost(), addr.getPort(), cfg.getTimeout());
@@ -78,6 +79,10 @@ public class ClusterConnectionManager extends MasterSlaveConnectionManager {
         monitorClusterChange(cfg);
     }
 
+    @Override
+    protected void initEntry(MasterSlaveServersConfig config) {
+    }
+
     private void addMasterEntry(ClusterPartition partition, ClusterServersConfig cfg) {
         if (partition.isMasterFail()) {
             return;