diff --git a/collector-terminal-management/src/main/java/com/docus/server/common/netty/client/handler/ClientHandler.java b/collector-terminal-management/src/main/java/com/docus/server/common/netty/client/handler/ClientHandler.java index b57bb09..f4d0749 100644 --- a/collector-terminal-management/src/main/java/com/docus/server/common/netty/client/handler/ClientHandler.java +++ b/collector-terminal-management/src/main/java/com/docus/server/common/netty/client/handler/ClientHandler.java @@ -19,7 +19,6 @@ import lombok.AllArgsConstructor; import lombok.NoArgsConstructor; import lombok.extern.slf4j.Slf4j; -import java.io.IOException; import java.io.Serializable; import java.util.Date; import java.util.List; @@ -152,15 +151,15 @@ public class ClientHandler extends SimpleChannelInboundHandler collectorRestartMsg = CommMsg.builder() - .content("重启虚拟机,操作成功!") + .content(result) .messageTime(DateUtil.formatDateTime(new Date())) .messageType(VIRTUAL_RESTART) .build(); - nettyClient.getCollectorChannelCacheMap().writeAndFlush(messageContent, collectorRestartMsg); + nettyClient.sendMessage(collectorRestartMsg); } private void collectorRestart(String messageContent) { @@ -188,7 +187,7 @@ public class ClientHandler extends SimpleChannelInboundHandler