You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ze...@apache.org on 2021/10/12 14:40:01 UTC
[incubator-streampipes] branch dev updated: [hotfix] Start set
adapter in an own thread
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
The following commit(s) were added to refs/heads/dev by this push:
new fd06d2f [hotfix] Start set adapter in an own thread
new 17e03d0 Merge branch 'dev' of github.com:apache/incubator-streampipes into dev
fd06d2f is described below
commit fd06d2ff0c6d2c1811442ed73844892f990b4aa4
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Tue Oct 12 16:39:29 2021 +0200
[hotfix] Start set adapter in an own thread
---
.../container/worker/management/AdapterWorkerManagement.java | 11 ++++++++++-
.../manager/execution/http/HttpRequestBuilder.java | 2 +-
2 files changed, 11 insertions(+), 2 deletions(-)
diff --git a/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/management/AdapterWorkerManagement.java b/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/management/AdapterWorkerManagement.java
index cf9d937..1c8d606 100644
--- a/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/management/AdapterWorkerManagement.java
+++ b/streampipes-connect-container-worker/src/main/java/org/apache/streampipes/connect/container/worker/management/AdapterWorkerManagement.java
@@ -58,7 +58,16 @@ public class AdapterWorkerManagement {
adapter.changeEventGrounding(adapterSetDescription.getDataSet().getEventGrounding().getTransportProtocol());
- adapter.startAdapter();
+ // Start a thread to start a set adapter
+ Runnable r = () -> {
+ try {
+ adapter.startAdapter();
+ } catch (AdapterException e) {
+ e.printStackTrace();
+ }
+ };
+
+ new Thread(r).start();
}
public void stopSetAdapter(AdapterSetDescription adapterSetDescription) throws AdapterException {
diff --git a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/HttpRequestBuilder.java b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/HttpRequestBuilder.java
index e04fd0f..a854edd 100644
--- a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/HttpRequestBuilder.java
+++ b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/execution/http/HttpRequestBuilder.java
@@ -47,7 +47,7 @@ public class HttpRequestBuilder {
try {
String jsonDocument = toJson();
Response httpResp =
- Request.Post(endpointUrl).bodyString(jsonDocument, ContentType.APPLICATION_JSON).connectTimeout(100000).execute();
+ Request.Post(endpointUrl).bodyString(jsonDocument, ContentType.APPLICATION_JSON).connectTimeout(10000).execute();
return handleResponse(httpResp);
} catch (Exception e) {
LOG.error(e.getMessage());