implement onError method for websocket connection (#5730)

Signed-off-by: Kai Kreuzer <kai@openhab.org>
openhab · Jun 16, 2019 · c11517a · c11517a
1 parent 5008890
commit c11517a
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 0 deletions.
diff --git a/...nding.kodi/src/main/java/org/openhab/binding/kodi/internal/protocol/KodiClientSocket.java b/...nding.kodi/src/main/java/org/openhab/binding/kodi/internal/protocol/KodiClientSocket.java
@@ -21,6 +21,7 @@
 import org.eclipse.jetty.websocket.api.Session;
 import org.eclipse.jetty.websocket.api.annotations.OnWebSocketClose;
 import org.eclipse.jetty.websocket.api.annotations.OnWebSocketConnect;
+import org.eclipse.jetty.websocket.api.annotations.OnWebSocketError;
 import org.eclipse.jetty.websocket.api.annotations.OnWebSocketMessage;
 import org.eclipse.jetty.websocket.api.annotations.WebSocket;
 import org.eclipse.jetty.websocket.client.ClientUpgradeRequest;
@@ -160,6 +161,12 @@ public void onClose(int statusCode, String reason) {
  });
  }
  }
+
+ @OnWebSocketError
+ public void onError(Throwable error) {
+ onClose(0, error.getMessage());
+ }
+
  }
 
  private void sendMessage(String str) throws IOException {

diff --git a/.../src/main/java/org/openhab/binding/sonyaudio/internal/protocol/SonyAudioClientSocket.java b/.../src/main/java/org/openhab/binding/sonyaudio/internal/protocol/SonyAudioClientSocket.java
@@ -24,6 +24,7 @@
 import org.eclipse.jetty.websocket.api.Session;
 import org.eclipse.jetty.websocket.api.annotations.OnWebSocketClose;
 import org.eclipse.jetty.websocket.api.annotations.OnWebSocketConnect;
+import org.eclipse.jetty.websocket.api.annotations.OnWebSocketError;
 import org.eclipse.jetty.websocket.api.annotations.OnWebSocketMessage;
 import org.eclipse.jetty.websocket.api.annotations.WebSocket;
 import org.eclipse.jetty.websocket.client.ClientUpgradeRequest;
@@ -191,6 +192,11 @@ public void onClose(int statusCode, String reason) {
  }
  });
  }
+
+ @OnWebSocketError
+ public void onError(Throwable error) {
+ onClose(0, error.getMessage());
+ }
  }
 
  private void sendMessage(String str) throws IOException {