|
29 | 29 | import java.util.TimerTask; |
30 | 30 | import java.util.concurrent.ExecutorService; |
31 | 31 | import java.util.concurrent.Executors; |
32 | | -import java.util.concurrent.SynchronousQueue; |
33 | | -import java.util.concurrent.ThreadPoolExecutor; |
34 | | -import java.util.concurrent.TimeUnit; |
35 | 32 |
|
36 | 33 | import javax.net.SocketFactory; |
37 | 34 | import javax.net.ssl.SSLSocketFactory; |
| 35 | + |
38 | 36 | import org.eclipse.paho.client.mqttv3.internal.ClientComms; |
39 | 37 | import org.eclipse.paho.client.mqttv3.internal.ConnectActionListener; |
40 | 38 | import org.eclipse.paho.client.mqttv3.internal.DisconnectedMessageBuffer; |
41 | 39 | import org.eclipse.paho.client.mqttv3.internal.ExceptionHelper; |
42 | | -import org.eclipse.paho.client.mqttv3.internal.LocalNetworkModule; |
43 | 40 | import org.eclipse.paho.client.mqttv3.internal.NetworkModule; |
44 | 41 | import org.eclipse.paho.client.mqttv3.internal.SSLNetworkModule; |
45 | 42 | import org.eclipse.paho.client.mqttv3.internal.TCPNetworkModule; |
46 | 43 | import org.eclipse.paho.client.mqttv3.internal.security.SSLSocketFactoryFactory; |
47 | | -import org.eclipse.paho.client.mqttv3.internal.websocket.WebSocketSecureNetworkModule; |
48 | 44 | import org.eclipse.paho.client.mqttv3.internal.websocket.WebSocketNetworkModule; |
| 45 | +import org.eclipse.paho.client.mqttv3.internal.websocket.WebSocketSecureNetworkModule; |
49 | 46 | import org.eclipse.paho.client.mqttv3.internal.wire.MqttDisconnect; |
50 | 47 | import org.eclipse.paho.client.mqttv3.internal.wire.MqttPublish; |
51 | 48 | import org.eclipse.paho.client.mqttv3.internal.wire.MqttSubscribe; |
@@ -574,9 +571,6 @@ else if ((factory instanceof SSLSocketFactory) == false) { |
574 | 571 | } |
575 | 572 | } |
576 | 573 | break; |
577 | | - case MqttConnectOptions.URI_TYPE_LOCAL : |
578 | | - netModule = new LocalNetworkModule(address.substring(8)); |
579 | | - break; |
580 | 574 | default: |
581 | 575 | // This shouldn't happen, as long as validateURI() has been called. |
582 | 576 | log.fine(CLASS_NAME,methodName, "119", new Object[] {address}); |
|
0 commit comments