From 5f5eb62bddf9833e54668b08d0e6b433af4b553e Mon Sep 17 00:00:00 2001 From: lucky 8 <1031900093@qq.com> Date: Sat, 23 Jul 2022 12:56:36 +0800 Subject: [PATCH] Fix Spring injection for Netty clients --- .../starter/monitor/send/netty/NettyConnectSender.java | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/send/netty/NettyConnectSender.java b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/send/netty/NettyConnectSender.java index 370aaf6b..5cfe4e0d 100644 --- a/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/send/netty/NettyConnectSender.java +++ b/hippo4j-spring-boot/hippo4j-spring-boot-starter/src/main/java/cn/hippo4j/springboot/starter/monitor/send/netty/NettyConnectSender.java @@ -43,7 +43,6 @@ import org.springframework.stereotype.Component; */ @Slf4j @AllArgsConstructor -@Component public class NettyConnectSender implements MessageSender { private ServerNettyAgent serverNettyAgent; @@ -59,7 +58,7 @@ public class NettyConnectSender implements MessageSender { .handler(new ChannelInitializer() { @Override - protected void initChannel(SocketChannel ch) throws Exception { + protected void initChannel(SocketChannel ch) { ChannelPipeline pipeline = ch.pipeline(); pipeline.addLast(new ObjectEncoder()); pipeline.addLast(new ObjectDecoder(Integer.MAX_VALUE, @@ -71,8 +70,6 @@ public class NettyConnectSender implements MessageSender { bootstrap.connect(serverNettyAgent.getNettyServerAddress(), serverNettyAgent.getNettyServerPort()).sync(); } catch (Exception e) { log.error("netty send error ", e); - } /* - * finally { eventLoopGroup.shutdownGracefully(); } - */ + } } }