Skip to content

Commit

Permalink
修复bug
Browse files Browse the repository at this point in the history
  • Loading branch information
puyang1017 committed Mar 31, 2020
1 parent 6653287 commit bb6879f
Showing 1 changed file with 1 addition and 5 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -27,14 +27,11 @@

import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.internal.TCPNetworkModule;
import org.eclipse.paho.client.mqttv3.logging.Logger;
import org.eclipse.paho.client.mqttv3.logging.LoggerFactory;

public class WebSocketNetworkModule extends TCPNetworkModule {

private static final String CLASS_NAME = WebSocketNetworkModule.class.getName();
private Logger log = LoggerFactory.getLogger(LoggerFactory.MQTT_CLIENT_MSG_CAT, CLASS_NAME);


private String uri;
private String host;
private int port;
Expand All @@ -58,7 +55,6 @@ public WebSocketNetworkModule(SocketFactory factory, String uri, String host, in
this.customWebsocketHeaders = customWebsocketHeaders;
this.pipedInputStream = new PipedInputStream();

log.setResourceName(resourceContext);
}

public void start() throws IOException, MqttException {
Expand Down

0 comments on commit bb6879f

Please sign in to comment.