This is an automated email from the ASF dual-hosted git repository.
vongosling pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
The following commit(s) were added to refs/heads/develop by this push:
new 7c36468 [ISSUE #3089] fix Print log format is incorrect in
NettyRemotingAbstract class (#3126)
7c36468 is described below
commit 7c364687c65bb1e9207600e1f4c1610363ae10bc
Author: mxsm <[email protected]>
AuthorDate: Mon Jul 5 16:09:34 2021 +0800
[ISSUE #3089] fix Print log format is incorrect in NettyRemotingAbstract
class (#3126)
---
.../java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
index 3f21eb8..c9b3994 100644
---
a/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
+++
b/remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
@@ -553,7 +553,7 @@ public abstract class NettyRemotingAbstract {
throw new RemotingTooMuchRequestException("invokeOnewayImpl
invoke too fast");
} else {
String info = String.format(
- "invokeOnewayImpl tryAcquire semaphore timeout, %dms,
waiting thread nums: %d semaphoreAsyncValue: %d",
+ "invokeOnewayImpl tryAcquire semaphore timeout, %dms,
waiting thread nums: %d semaphoreOnewayValue: %d",
timeoutMillis,
this.semaphoreOneway.getQueueLength(),
this.semaphoreOneway.availablePermits()