Skip to content

Commit 02fc62b

Browse files
IGNITE-26209 Review comments fixed
1 parent bf092f5 commit 02fc62b

File tree

1 file changed

+2
-4
lines changed

1 file changed

+2
-4
lines changed

modules/core/src/main/java/org/apache/ignite/spi/communication/tcp/internal/GridNioServerWrapper.java

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1273,11 +1273,9 @@ private void checkNodeQueueSize(GridNioSession ses, int msgQueueSize) {
12731273
if (lastMsqQueueSizeWarningTs.compareAndSet(lastWarnTs, U.currentTimeMillis())) {
12741274
ConnectionKey id = ses.meta(CONN_IDX_META);
12751275
if (id != null) {
1276-
String msg = "Outbound message queue size for node exceeded configured " +
1276+
log.warning("Outbound message queue size for node exceeded configured " +
12771277
"messageQueueWarningSize value, it may be caused by node failure or a network problems " +
1278-
"[node=" + id.nodeId() + ", msqQueueSize=" + msgQueueSize + ']';
1279-
1280-
log.warning(msg);
1278+
"[node=" + id.nodeId() + ", msqQueueSize=" + msgQueueSize + ']');
12811279
}
12821280
}
12831281
}

0 commit comments

Comments
 (0)