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();
private WebSocketClient client;
private String controllerAddress;
+ private int port;
private TouchWandSocket touchWandSocket;
private boolean isShutDown = false;
private CopyOnWriteArraySet<TouchWandUnitStatusUpdateListener> listeners = new CopyOnWriteArraySet<>();
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;