Merge pull request #432 from lyl625760/master

Fix semphore usage in oneway invokoing
huyangyamin · Dec 13, 2016 · 860e55e · 860e55e
2 parents 4cc93bd + 8d8e0c3
commit 860e55e
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);