From 9ea88c78637b1063d8c0e4ca4cea44e6a1b62d31 Mon Sep 17 00:00:00 2001
From: luoyaogui <luoyg@apical.com.cn>
Date: Tue, 27 Jun 2017 15:03:16 +0800
Subject: [PATCH] Update SocketChannelPool.java

---
 .../canal/parse/driver/mysql/socket/SocketChannelPool.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/SocketChannelPool.java b/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/SocketChannelPool.java
index 3d6d17c7..e7d791a3 100644
--- a/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/SocketChannelPool.java
+++ b/driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/SocketChannelPool.java
@@ -54,7 +54,7 @@ public abstract class SocketChannelPool {
 			@Override
 			public void operationComplete(ChannelFuture arg0) throws Exception {
 				if(arg0.isSuccess())
-					socket.setChannel(arg0.channel(),false);
+					socket.setChannel(arg0.channel());
 				synchronized (socket) {
 					socket.notify();
 				}
@@ -73,7 +73,7 @@ public abstract class SocketChannelPool {
 		private SocketChannel socket=null;
 		@Override
 		public void channelInactive(ChannelHandlerContext ctx) throws Exception {
-			socket.setChannel(null,true);
+			socket.setChannel(null);
 			chManager.remove(ctx.channel());//移除
 		}
 		@Override