Skip to content

Commit

Permalink
Code cleanup (#226)
Browse files Browse the repository at this point in the history
  • Loading branch information
Yin Hang authored Aug 4, 2022
1 parent bb91257 commit 5264cc4
Showing 1 changed file with 0 additions and 7 deletions.
7 changes: 0 additions & 7 deletions src/main/java/io/vertx/mqtt/impl/MqttClientImpl.java
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,6 @@
import io.vertx.core.impl.logging.Logger;
import io.vertx.core.impl.logging.LoggerFactory;
import io.vertx.core.net.NetClient;
import io.vertx.core.net.NetClientOptions;
import io.vertx.core.net.impl.VertxHandler;
import io.vertx.mqtt.MqttClient;
import io.vertx.mqtt.MqttClientOptions;
Expand Down Expand Up @@ -94,7 +93,6 @@ private enum Status { CLOSED, CONNECTING, CONNECTED, CLOSING }
private static final int MIN_TOPIC_LEN = 1;
private static final String PROTOCOL_NAME = "MQTT";
private static final int PROTOCOL_VERSION = 4;
private static final int DEFAULT_IDLE_TIMEOUT = 0;

private final VertxInternal vertx;
private final MqttClientOptions options;
Expand Down Expand Up @@ -154,11 +152,6 @@ private enum Status { CLOSED, CONNECTING, CONNECTED, CLOSING }
* @param options MQTT client options
*/
public MqttClientImpl(Vertx vertx, MqttClientOptions options) {

// copy given options
NetClientOptions netClientOptions = new NetClientOptions(options);
netClientOptions.setIdleTimeout(DEFAULT_IDLE_TIMEOUT);

this.vertx = (VertxInternal) vertx;
this.options = new MqttClientOptions(options);
this.keepAliveTimeout = ((options.getKeepAliveInterval() * 1000) * 3) / 2;
Expand Down

0 comments on commit 5264cc4

Please sign in to comment.