From 9ef8f477d5f7e891c7e2af05aeb66adf9bf178f5 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=B5=B5=E5=BB=B6?= <horizonzy@apache.org>
Date: Fri, 10 Dec 2021 23:04:08 +0800
Subject: [PATCH] [ISSUE #2535] Polish log variable. (#2536)

* [ISSUE #2535] Use one variable value to log info when eventQueue's size more than 10000.

* add the queue limit value when evenQueue size is enough.
---
 .../rocketmq/remoting/netty/NettyRemotingAbstract.java       | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

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 b2e7294bf32..f02518bebe5 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
@@ -570,10 +570,11 @@ class NettyEventExecutor extends ServiceThread {
         private final int maxSize = 10000;
 
         public void putNettyEvent(final NettyEvent event) {
-            if (this.eventQueue.size() <= maxSize) {
+            int currentSize = this.eventQueue.size();
+            if (currentSize <= maxSize) {
                 this.eventQueue.add(event);
             } else {
-                log.warn("event queue size[{}] enough, so drop this event {}", this.eventQueue.size(), event.toString());
+                log.warn("event queue size [{}] over the limit [{}], so drop this event {}", currentSize, maxSize, event.toString());
             }
         }