From edfc6195a4931222918a83abbc5e594b7ed8168c Mon Sep 17 00:00:00 2001
From: Felix <felix.lin@nogle.com>
Date: Thu, 17 Dec 2015 12:04:26 +0800
Subject: [PATCH] fix Low level Redis client shutdown issue: eventloopgroup 
 won't be shutdown. The eventloopgroup should be shutdown gracefully

---
 src/main/java/org/redisson/client/RedisClient.java | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/src/main/java/org/redisson/client/RedisClient.java b/src/main/java/org/redisson/client/RedisClient.java
index c776be70a..9f26260b7 100644
--- a/src/main/java/org/redisson/client/RedisClient.java
+++ b/src/main/java/org/redisson/client/RedisClient.java
@@ -49,7 +49,7 @@ public class RedisClient {
     private final long timeout;
 
     public RedisClient(String host, int port) {
-        this(new NioEventLoopGroup(), NioSocketChannel.class, host, port, 60*1000);
+        this(new NioEventLoopGroup(), NioSocketChannel.class, host, port, 60 * 1000);
     }
 
     public RedisClient(EventLoopGroup group, Class<? extends SocketChannel> socketChannelClass, String host, int port, int timeout) {
@@ -59,10 +59,10 @@ public class RedisClient {
             @Override
             protected void initChannel(Channel ch) throws Exception {
                 ch.pipeline().addFirst(new ConnectionWatchdog(bootstrap, channels),
-                                        new CommandEncoder(),
-                                        new CommandsListEncoder(),
-                                        new CommandsQueue(),
-                                        new CommandDecoder());
+                    new CommandEncoder(),
+                    new CommandsListEncoder(),
+                    new CommandsQueue(),
+                    new CommandDecoder());
             }
         });
 
@@ -138,6 +138,7 @@ public class RedisClient {
 
     public void shutdown() {
         shutdownAsync().syncUninterruptibly();
+        bootstrap.group().shutdownGracefully();
     }
 
     public ChannelGroupFuture shutdownAsync() {
@@ -150,4 +151,3 @@ public class RedisClient {
     }
 
 }
-