This is an automated email from the ASF dual-hosted git repository. lizhanhui pushed a commit to branch keep_alive in repository https://gitbox.apache.org/repos/asf/rocketmq-mqtt.git
commit e322e681f290fc1a2ca4e124b4b3379246082825 Author: Li Zhanhui <[email protected]> AuthorDate: Wed Apr 17 13:38:22 2024 +0800 fix: socket option keep_alive shall be a child option in netty Signed-off-by: Li Zhanhui <[email protected]> --- .../src/main/java/org/apache/rocketmq/mqtt/cs/starter/MqttServer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/starter/MqttServer.java b/mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/starter/MqttServer.java index 81a77b2..f4d0183 100644 --- a/mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/starter/MqttServer.java +++ b/mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/starter/MqttServer.java @@ -135,7 +135,7 @@ public class MqttServer { .group(new NioEventLoopGroup(connectConf.getNettySelectorThreadNum()), new NioEventLoopGroup(connectConf.getNettyWorkerThreadNum())) .channel(NioServerSocketChannel.class) .option(ChannelOption.SO_BACKLOG, 8 * 1024) - .option(ChannelOption.SO_KEEPALIVE, true) + .childOption(ChannelOption.SO_KEEPALIVE, true) .childOption(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT) .childOption(ChannelOption.WRITE_BUFFER_WATER_MARK,new WriteBufferWaterMark(connectConf.getLowWater(), connectConf.getHighWater())) .childOption(ChannelOption.TCP_NODELAY, true) @@ -159,4 +159,4 @@ public class MqttServer { logger.warn("start mqtt ws server , port:{}", port); } -} \ No newline at end of file +}
