From 3e7e7b7f6e0cd9a525ecf96b3192e7f47d262d15 Mon Sep 17 00:00:00 2001
From: Wu-Jianqiang <959007@163.com>
Date: Mon, 26 Feb 2018 16:37:21 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=EF=BC=9A=E5=8F=98=E9=87=8F?=
 =?UTF-8?q?=E5=91=BD=E5=90=8D=E5=92=8Csuper=E8=B0=83=E7=94=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../canal/parse/driver/mysql/socket/SocketChannelPool.java   | 5 +++--
 1 file changed, 3 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 fa16a829..efec72c6 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
@@ -48,8 +48,8 @@ public abstract class SocketChannelPool {
             .handler(new ChannelInitializer() {
 
                 @Override
-                protected void initChannel(Channel arg0) throws Exception {
-                    arg0.pipeline().addLast(new BusinessHandler());// 命令过滤和handler添加管理
+                protected void initChannel(Channel ch) throws Exception {
+                    ch.pipeline().addLast(new BusinessHandler());// 命令过滤和handler添加管理
                 }
             });
     }
@@ -79,6 +79,7 @@ public abstract class SocketChannelPool {
         public void channelInactive(ChannelHandlerContext ctx) throws Exception {
             socket.setChannel(null);
             chManager.remove(ctx.channel());// 移除
+            super.channelInactive(ctx);
         }
 
         @Override