From 081aa927e49ed517ffb24c3680a55417489be38a Mon Sep 17 00:00:00 2001 From: Kai Kreuzer Date: Sun, 16 Jun 2019 16:35:11 +0200 Subject: [PATCH] implement onError method for websocket connection (#5730) Signed-off-by: Kai Kreuzer --- .../binding/kodi/internal/protocol/KodiClientSocket.java | 7 +++++++ .../sonyaudio/internal/protocol/SonyAudioClientSocket.java | 6 ++++++ 2 files changed, 13 insertions(+) diff --git a/bundles/org.openhab.binding.kodi/src/main/java/org/openhab/binding/kodi/internal/protocol/KodiClientSocket.java b/bundles/org.openhab.binding.kodi/src/main/java/org/openhab/binding/kodi/internal/protocol/KodiClientSocket.java index ef063ba0a70b3..0f4e37086779f 100644 --- a/bundles/org.openhab.binding.kodi/src/main/java/org/openhab/binding/kodi/internal/protocol/KodiClientSocket.java +++ b/bundles/org.openhab.binding.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/bundles/org.openhab.binding.sonyaudio/src/main/java/org/openhab/binding/sonyaudio/internal/protocol/SonyAudioClientSocket.java b/bundles/org.openhab.binding.sonyaudio/src/main/java/org/openhab/binding/sonyaudio/internal/protocol/SonyAudioClientSocket.java index 8e26f37111bb8..4143593af2d1c 100644 --- a/bundles/org.openhab.binding.sonyaudio/src/main/java/org/openhab/binding/sonyaudio/internal/protocol/SonyAudioClientSocket.java +++ b/bundles/org.openhab.binding.sonyaudio/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 {