From bd1eeb49286b6c00952e162884058a0853bcd667 Mon Sep 17 00:00:00 2001 From: dnwick Date: Fri, 9 Apr 2021 14:20:25 +0530 Subject: [PATCH 1/2] Fix extension description and sample explanation --- .../websocket/sink/websocketserver/WebSocketServerSink.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/component/src/main/java/io/siddhi/extension/io/websocket/sink/websocketserver/WebSocketServerSink.java b/component/src/main/java/io/siddhi/extension/io/websocket/sink/websocketserver/WebSocketServerSink.java index 60db4b6..28b6f3f 100644 --- a/component/src/main/java/io/siddhi/extension/io/websocket/sink/websocketserver/WebSocketServerSink.java +++ b/component/src/main/java/io/siddhi/extension/io/websocket/sink/websocketserver/WebSocketServerSink.java @@ -45,7 +45,7 @@ @Extension( name = "websocket-server", namespace = "sink", - description = "A Siddhi application can be configured to publish events via the WebSocket transport by " + + description = "A Siddhi application can be configured to run as a websocket server by " + "adding the @Sink(type = 'websocket-server') annotation at the top of an event stream definition.", parameters = { @Parameter( @@ -108,8 +108,8 @@ "define stream Foo (attribute1 string, attribute2 int);", description = "" + "A sink of type 'websocket-server' has been defined.\n" + - "All events arriving at Foo stream via websocket-server will be sent " + - "to the url ws://localhost:9025/abc." + "Clients can connect to ws://localhost:9025/abc. All events arriving at " + + "Foo stream will be sent to all the clients who got connected." ) } ) From 0ee68829c5e0ebd6aea283e19bbe0dd36401bdc8 Mon Sep 17 00:00:00 2001 From: dnwick Date: Fri, 9 Apr 2021 14:25:35 +0530 Subject: [PATCH 2/2] Fix extension sample explanation of websocket sink --- .../io/siddhi/extension/io/websocket/sink/WebSocketSink.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/component/src/main/java/io/siddhi/extension/io/websocket/sink/WebSocketSink.java b/component/src/main/java/io/siddhi/extension/io/websocket/sink/WebSocketSink.java index 246cc71..d688aab 100644 --- a/component/src/main/java/io/siddhi/extension/io/websocket/sink/WebSocketSink.java +++ b/component/src/main/java/io/siddhi/extension/io/websocket/sink/WebSocketSink.java @@ -119,8 +119,8 @@ "define stream Foo (attribute1 string, attribute2 int);", description = "" + "A sink of type 'websocket' has been defined.\n" + - "All events arriving at Foo stream via websocket will be sent " + - "to the url ws://localhost:8025/abc." + "All events arriving at Foo stream will be sent " + + "to the url ws://localhost:8025/abc where the websocket server resides." ) } )