Override IdleTimeout to fix Error

vert-x3 · Jun 15, 2018 · 77e412c · 77e412c
1 parent d5fecba
commit 77e412c
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 1 deletion.
diff --git a/src/main/java/io/vertx/mqtt/MqttServerOptions.java b/src/main/java/io/vertx/mqtt/MqttServerOptions.java
@@ -258,4 +258,12 @@ public MqttServerOptions setTimeoutOnConnect(int timeoutOnConnect) {
   public int timeoutOnConnect() {
     return this.timeoutOnConnect;
   }
+
+  /**
+   * @return  the TCP idle timeout, in seconds,In Mqtt Server the Parameter will be invaild, it will use timeoutOnConnect.
+   */
+  @Override
+  public int getIdleTimeout() {
+    return 0;
+  }
 }
diff --git a/src/main/java/io/vertx/mqtt/impl/MqttServerImpl.java b/src/main/java/io/vertx/mqtt/impl/MqttServerImpl.java
@@ -138,7 +138,7 @@ private void initChannel(ChannelPipeline pipeline) {
     }
 
     // adding the idle state handler for timeout on CONNECT packet
-    pipeline.addBefore("handler", "mqttIdle", new IdleStateHandler(this.options.timeoutOnConnect(), 0, 0));
+    pipeline.addBefore("handler", "idle", new IdleStateHandler(this.options.timeoutOnConnect(), 0, 0));
     pipeline.addBefore("handler", "timeoutOnConnect", new ChannelDuplexHandler() {
 
       @Override
@@ -154,5 +154,6 @@ public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exc
         }
       }
     });
+
   }
 }