You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by bo...@apache.org on 2022/09/22 17:07:49 UTC
[incubator-streampipes] 01/02: authenticate during schema guessing as well
This is an automated email from the ASF dual-hosted git repository.
bossenti pushed a commit to branch explore/websocket-adapter
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
commit 9177d39bac2d9492fb75769781c7405e58ad9237
Author: bossenti <bo...@posteo.de>
AuthorDate: Thu Sep 22 18:21:45 2022 +0200
authenticate during schema guessing as well
---
.../connect/iiot/protocol/stream/websocket/WebsocketAdapter.java | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/websocket/WebsocketAdapter.java b/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/websocket/WebsocketAdapter.java
index 60a83e774..afb1e813f 100644
--- a/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/websocket/WebsocketAdapter.java
+++ b/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/websocket/WebsocketAdapter.java
@@ -117,7 +117,10 @@ public class WebsocketAdapter extends BrokerProtocol {
List<byte[]> elements = new ArrayList<>();
InternalEventProcessor<byte[]> eventProcessor = elements::add;
- SpWebSocketClient socketClient = new SpWebSocketClient(URI.create(this.brokerUrl), eventProcessor);
+ HashMap<String, String> httpHeader = new HashMap<>();
+ httpHeader.put("Authorization", "Bearer " + this.authToken);
+
+ SpWebSocketClient socketClient = new SpWebSocketClient(URI.create(this.brokerUrl), eventProcessor, httpHeader);
socketClient.connect();