Update NettyRemotingAbstract.java

// fix an code error .
huyangyamin · Dec 6, 2016 · 8d8e0c3 · 8d8e0c3
1 parent 4cc93bd
commit 8d8e0c3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...tmq-remoting/src/main/java/com/alibaba/rocketmq/remoting/netty/NettyRemotingAbstract.java b/...tmq-remoting/src/main/java/com/alibaba/rocketmq/remoting/netty/NettyRemotingAbstract.java
@@ -379,8 +379,8 @@ public void operationComplete(ChannelFuture f) throws Exception {
                 String info = String.format(
                         "invokeOnewayImpl tryAcquire semaphore timeout, %dms, waiting thread nums: %d semaphoreAsyncValue: %d", //
                         timeoutMillis, //
-                        this.semaphoreAsync.getQueueLength(), //
-                        this.semaphoreAsync.availablePermits()//
+                        this.semaphoreOneway.getQueueLength(), //
+                        this.semaphoreOneway.availablePermits()//
                 );
                 plog.warn(info);
                 throw new RemotingTimeoutException(info);