diff --git a/collector/src/main/java/org/apache/hertzbeat/collector/dispatch/entrance/processor/GoOfflineProcessor.java b/collector/src/main/java/org/apache/hertzbeat/collector/dispatch/entrance/processor/GoOfflineProcessor.java index 1e8dbb2b041..007b77053ba 100644 --- a/collector/src/main/java/org/apache/hertzbeat/collector/dispatch/entrance/processor/GoOfflineProcessor.java +++ b/collector/src/main/java/org/apache/hertzbeat/collector/dispatch/entrance/processor/GoOfflineProcessor.java @@ -41,7 +41,6 @@ public ClusterMsg.Message handle(ChannelHandlerContext ctx, ClusterMsg.Message m } timerDispatch.goOffline(); log.info("receive offline message and handle success"); - message.getMsg(); if (message.getMsg().contains(CommonConstants.COLLECTOR_AUTH_FAILED)) { log.error("[Auth Failed]receive client auth failed message and go offline. {}", message.getMsg()); return null; diff --git a/remoting/src/main/java/org/apache/hertzbeat/remoting/netty/NettyRemotingAbstract.java b/remoting/src/main/java/org/apache/hertzbeat/remoting/netty/NettyRemotingAbstract.java index 09b4dc4f4d2..a9632d7c401 100644 --- a/remoting/src/main/java/org/apache/hertzbeat/remoting/netty/NettyRemotingAbstract.java +++ b/remoting/src/main/java/org/apache/hertzbeat/remoting/netty/NettyRemotingAbstract.java @@ -26,6 +26,7 @@ import java.util.List; import java.util.concurrent.ConcurrentHashMap; import lombok.extern.slf4j.Slf4j; +import org.apache.commons.collections4.CollectionUtils; import org.apache.hertzbeat.common.entity.message.ClusterMsg; import org.apache.hertzbeat.common.util.NetworkUtil; import org.apache.hertzbeat.remoting.RemotingService; @@ -77,7 +78,7 @@ protected void processRequestMsg(ChannelHandlerContext ctx, ClusterMsg.Message r } private void doBeforeRequest(ChannelHandlerContext ctx, ClusterMsg.Message request) { - if (this.nettyHookList == null || this.nettyHookList.isEmpty()) { + if (CollectionUtils.isEmpty(this.nettyHookList)) { return; } for (NettyHook nettyHook : this.nettyHookList) {