diff --git a/src-plugin/com/wentch/redkale/net/icep/IcepContext.java b/src-plugin/com/wentch/redkale/net/icep/IcepContext.java
index 5b17588ff..88052e0bd 100644
--- a/src-plugin/com/wentch/redkale/net/icep/IcepContext.java
+++ b/src-plugin/com/wentch/redkale/net/icep/IcepContext.java
@@ -23,10 +23,10 @@ public final class IcepContext extends Context {
 
     protected final BsonFactory bsonFactory;
 
-    public IcepContext(long serverStartTime, Logger logger, ExecutorService executor, ObjectPool<ByteBuffer> bufferPool,
+    public IcepContext(long serverStartTime, Logger logger, ExecutorService executor, int bufferCapacity, ObjectPool<ByteBuffer> bufferPool,
             ObjectPool<Response> responsePool, int maxbody, Charset charset, InetSocketAddress address, PrepareServlet prepare,
             WatchFactory watch, int readTimeoutSecond, int writeTimeoutSecond) {
-        super(serverStartTime, logger, executor, bufferPool, responsePool, maxbody, charset,
+        super(serverStartTime, logger, executor, bufferCapacity, bufferPool, responsePool, maxbody, charset,
                 address, prepare, watch, readTimeoutSecond, writeTimeoutSecond);
         this.bsonFactory = BsonFactory.root();
     }
diff --git a/src-plugin/com/wentch/redkale/net/icep/IcepServer.java b/src-plugin/com/wentch/redkale/net/icep/IcepServer.java
index de99f5556..5e7937046 100644
--- a/src-plugin/com/wentch/redkale/net/icep/IcepServer.java
+++ b/src-plugin/com/wentch/redkale/net/icep/IcepServer.java
@@ -50,7 +50,7 @@ public final class IcepServer extends Server {
         AtomicLong createResponseCounter = watch == null ? new AtomicLong() : watch.createWatchNumber("ICEP_" + port + ".Response.creatCounter");
         AtomicLong cycleResponseCounter = watch == null ? new AtomicLong() : watch.createWatchNumber("ICEP_" + port + ".Response.cycleCounter");
         ObjectPool<Response> responsePool = IcepResponse.createPool(createResponseCounter, cycleResponseCounter, this.responsePoolSize, null);
-        IcepContext localcontext = new IcepContext(this.serverStartTime, this.logger, executor, bufferPool, responsePool,
+        IcepContext localcontext = new IcepContext(this.serverStartTime, this.logger, executor, rcapacity, bufferPool, responsePool,
                 this.maxbody, this.charset, this.address, this.prepare, this.watch, this.readTimeoutSecond, this.writeTimeoutSecond);
         responsePool.setCreator((Object... params) -> new IcepResponse(localcontext, new IcepRequest(localcontext)));
         return localcontext;
diff --git a/src-plugin/com/wentch/redkale/net/socks/SocksServer.java b/src-plugin/com/wentch/redkale/net/socks/SocksServer.java
index 3b1613d15..d7d628f26 100644
--- a/src-plugin/com/wentch/redkale/net/socks/SocksServer.java
+++ b/src-plugin/com/wentch/redkale/net/socks/SocksServer.java
@@ -51,7 +51,7 @@ public final class SocksServer extends Server {
         AtomicLong createResponseCounter = watch == null ? new AtomicLong() : watch.createWatchNumber("SOCKS_" + port + ".Response.creatCounter");
         AtomicLong cycleResponseCounter = watch == null ? new AtomicLong() : watch.createWatchNumber("SOCKS_" + port + ".Response.cycleCounter");
         ObjectPool<Response> responsePool = SocksResponse.createPool(createResponseCounter, cycleResponseCounter, this.responsePoolSize, null);
-        HttpContext localcontext = new HttpContext(this.serverStartTime, this.logger, executor, bufferPool, responsePool,
+        HttpContext localcontext = new HttpContext(this.serverStartTime, this.logger, executor, rcapacity, bufferPool, responsePool,
                 this.maxbody, this.charset, this.address, this.prepare, this.watch, this.readTimeoutSecond, this.writeTimeoutSecond, "");
         responsePool.setCreator((Object... params) -> new SocksResponse(localcontext, new SocksRequest(localcontext)));
         return localcontext;