From 812f83446e9b402329eed140f39393561d060faa Mon Sep 17 00:00:00 2001
From: Redkale <22250530@qq.com>
Date: Mon, 16 Apr 2018 13:29:12 +0800
Subject: [PATCH]

---
 src/org/redkale/source/PoolTcpSource.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/org/redkale/source/PoolTcpSource.java b/src/org/redkale/source/PoolTcpSource.java
index 647d4b4e4..58d381986 100644
--- a/src/org/redkale/source/PoolTcpSource.java
+++ b/src/org/redkale/source/PoolTcpSource.java
@@ -51,7 +51,7 @@ public abstract class PoolTcpSource extends PoolSource<AsyncConnection> {
         return pollAsync().join();
     }
 
-    protected abstract ByteBuffer reqConnectBuffer();
+    protected abstract ByteBuffer reqConnectBuffer(AsyncConnection conn);
 
     protected abstract void respConnectBuffer(final ByteBuffer buffer, CompletableFuture<AsyncConnection> future, AsyncConnection conn);
 
@@ -59,7 +59,7 @@ public abstract class PoolTcpSource extends PoolSource<AsyncConnection> {
     public CompletableFuture<AsyncConnection> pollAsync() {
         return AsyncConnection.createTCP(group, this.servaddr, this.readTimeoutSeconds, this.writeTimeoutSeconds).thenCompose(conn -> {
             CompletableFuture<AsyncConnection> future = new CompletableFuture();
-            final ByteBuffer buffer = reqConnectBuffer();
+            final ByteBuffer buffer = reqConnectBuffer(conn);
             conn.write(buffer, null, new CompletionHandler<Integer, Void>() {
                 @Override
                 public void completed(Integer result, Void attachment1) {