Fixed - connection is not reconnected #1811

6 years ago · 44ea59f9f6
parent eb4200dfea
commit 44ea59f9f6
1 changed files with 2 additions and 2 deletions
--- a/redisson/src/main/java/org/redisson/client/handler/ConnectionWatchdog.java
+++ b/redisson/src/main/java/org/redisson/client/handler/ConnectionWatchdog.java
@ -133,9 +133,9 @@ public class ConnectionWatchdog extends ChannelInboundHandlerAdapter {
                                        refresh(connection, channel);
                                        log.debug("{} connected to {}, command: {}", connection, connection.getRedisClient().getAddr(), connection.getCurrentCommand());
                                    } else {
-                                        log.warn("Can't connect " + connection + " to " + connection.getRedisClient().getAddr(), future.cause());
+                                        channel.close();
+                                        reconnect(connection, nextAttempt);
                                    }
-                                    
                                }
                            });
                            return;