[incubator-streampipes-extensions] branch dev updated: Throw SpRuntimeException if exception occurs in onDetatch() of websocket server

[mh...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

mheyden pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git


The following commit(s) were added to refs/heads/dev by this push:
     new 589ec38  Throw SpRuntimeException if exception occurs in onDetatch() of websocket server
     new 79bada9  Merge branch 'dev' of github.com:apache/incubator-streampipes-extensions into dev
589ec38 is described below

commit 589ec383b6c3fb4286482fcfa5f47ce449218cf7
Author: heymarco <he...@gmail.com>
AuthorDate: Thu Mar 11 09:49:27 2021 +0100

    Throw SpRuntimeException if exception occurs in onDetatch() of websocket server
---
 .../streampipes/sinks/brokers/jvm/websocket/WebsocketServerSink.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/websocket/WebsocketServerSink.java b/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/websocket/WebsocketServerSink.java
index 889368a..b5651fa 100644
--- a/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/websocket/WebsocketServerSink.java
+++ b/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/websocket/WebsocketServerSink.java
@@ -58,6 +58,7 @@ public class WebsocketServerSink extends StreamPipesDataSink {
     public void onInvocation(SinkParams parameters, EventSinkRuntimeContext runtimeContext) throws SpRuntimeException {
         port = parameters.extractor().singleValueParameter(PORT_KEY, Integer.class);
         server = new SocketServer(port);
+        server.setReuseAddr(true);
         server.start();
     }
 
@@ -70,8 +71,9 @@ public class WebsocketServerSink extends StreamPipesDataSink {
     public void onDetach() throws SpRuntimeException {
         try {
             server.stop();
+            server = null;
         } catch (IOException | InterruptedException e) {
-            e.printStackTrace();
+            throw new SpRuntimeException(e.getMessage());
         }
     }
 }