diff --git a/jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServer.java b/jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServer.java index dcd3cf0c0..bf01b9f9b 100644 --- a/jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServer.java +++ b/jsowell-netty/src/main/java/com/jsowell/netty/server/yunkuaichong/NettyServer.java @@ -66,7 +66,7 @@ public class NettyServer implements CommandLineRunner { } // 关闭channel和块,直到它被关闭 (若取消注释,则 MQTT 服务器无法启动) - // future.channel().closeFuture().sync(); + future.channel().closeFuture().sync(); } catch (Exception e) { log.error("NettyServer.start error", e); bossGroup.shutdownGracefully();