From d852c1b0720ffaaaf0ad3c236fe5f1d60dc93bb8 Mon Sep 17 00:00:00 2001 From: Nikita Date: Wed, 15 Jul 2015 15:09:18 +0300 Subject: [PATCH] minor fixes --- .../org/redisson/client/handler/ConnectionWatchdog.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/main/java/org/redisson/client/handler/ConnectionWatchdog.java b/src/main/java/org/redisson/client/handler/ConnectionWatchdog.java index 595d509be..9c675a537 100644 --- a/src/main/java/org/redisson/client/handler/ConnectionWatchdog.java +++ b/src/main/java/org/redisson/client/handler/ConnectionWatchdog.java @@ -18,8 +18,8 @@ public class ConnectionWatchdog extends ChannelInboundHandlerAdapter { private final Logger log = LoggerFactory.getLogger(getClass()); - private Bootstrap bootstrap; - private ChannelGroup channels; + private final Bootstrap bootstrap; + private final ChannelGroup channels; private static final int BACKOFF_CAP = 12; public ConnectionWatchdog(Bootstrap bootstrap, ChannelGroup channels) { @@ -57,7 +57,7 @@ public class ConnectionWatchdog extends ChannelInboundHandlerAdapter { return; } - log.debug("reconnecting connection {} to {} ", connection, connection.getRedisClient().getAddr(), connection); + log.debug("reconnecting {} to {} ", connection, connection.getRedisClient().getAddr(), connection); bootstrap.connect().addListener(new GenericFutureListener() { @Override @@ -67,7 +67,7 @@ public class ConnectionWatchdog extends ChannelInboundHandlerAdapter { } if (future.isSuccess()) { - log.debug("connection {} connected to {}", connection, connection.getRedisClient().getAddr()); + log.debug("{} connected to {}", connection, connection.getRedisClient().getAddr()); connection.updateChannel(future.channel()); return; }