]> git.basschouten.com Git - openhab-addons.git/commitdiff
[touchwand] Add port configuration to websocket (#13440)
authorRoie Geron <roie.geron@gmail.com>
Mon, 26 Sep 2022 17:05:50 +0000 (20:05 +0300)
committerGitHub <noreply@github.com>
Mon, 26 Sep 2022 17:05:50 +0000 (19:05 +0200)
* add port configuration to websocket

Signed-off-by: Roie Geron <roie.geron@gmail.com>
bundles/org.openhab.binding.touchwand/src/main/java/org/openhab/binding/touchwand/internal/TouchWandBridgeHandler.java
bundles/org.openhab.binding.touchwand/src/main/java/org/openhab/binding/touchwand/internal/TouchWandWebSockets.java

index 669307af4c9edece6429a50c86c5dec407245c02..ed269b6b7458b2b9d7336858b8465141b4712bde 100644 (file)
@@ -85,7 +85,7 @@ public class TouchWandBridgeHandler extends BaseBridgeHandler implements TouchWa
                 updateStatus(ThingStatus.ONLINE);
                 synchronized (this) {
                     if (isRunning) {
-                        TouchWandWebSockets localSockets = touchWandWebSockets = new TouchWandWebSockets(host,
+                        TouchWandWebSockets localSockets = touchWandWebSockets = new TouchWandWebSockets(host, port,
                                 scheduler);
                         localSockets.registerListener(this);
                         localSockets.connect();
index 97a4241ba2c05a03f0413a7aec230642b7e580e9..17403f98ba7f1467d7e3d1cebaf472b65880e96d 100644 (file)
@@ -59,6 +59,7 @@ public class TouchWandWebSockets {
 
     private WebSocketClient client;
     private String controllerAddress;
+    private int port;
     private TouchWandSocket touchWandSocket;
     private boolean isShutDown = false;
     private CopyOnWriteArraySet<TouchWandUnitStatusUpdateListener> listeners = new CopyOnWriteArraySet<>();
@@ -67,17 +68,18 @@ public class TouchWandWebSockets {
 
     private ScheduledExecutorService scheduler;
 
-    public TouchWandWebSockets(String ipAddress, ScheduledExecutorService scheduler) {
+    public TouchWandWebSockets(String ipAddress, int port, ScheduledExecutorService scheduler) {
         client = new WebSocketClient();
         touchWandSocket = new TouchWandSocket();
         this.controllerAddress = ipAddress;
+        this.port = port;
         this.scheduler = scheduler;
         socketReconnect = null;
     }
 
     public void connect() {
         try {
-            uri = new URI("ws://" + controllerAddress + WS_ENDPOINT_TOUCHWAND);
+            uri = new URI("ws://" + controllerAddress + ":" + String.valueOf(port) + WS_ENDPOINT_TOUCHWAND);
         } catch (URISyntaxException e) {
             logger.warn("URI not valid {} message {}", uri, e.getMessage());
             return;