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 2020/06/01 10:30:09 UTC
[incubator-streampipes] branch dev updated: [STREAMPIPES-152] Fix
by removing the second decryption step
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 09da1e4 [STREAMPIPES-152] Fix by removing the second decryption step
09da1e4 is described below
commit 09da1e48a69ff9cc5ad365b55d6382f7b1815f39
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Mon Jun 1 12:29:27 2020 +0200
[STREAMPIPES-152] Fix by removing the second decryption step
---
.../connect/container/master/management/SourcesManagement.java | 8 +-------
1 file changed, 1 insertion(+), 7 deletions(-)
diff --git a/streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/management/SourcesManagement.java b/streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/management/SourcesManagement.java
index 6805bec..065500d 100644
--- a/streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/management/SourcesManagement.java
+++ b/streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/management/SourcesManagement.java
@@ -70,15 +70,9 @@ public class SourcesManagement {
adapterDescription.setId(newId);
AdapterSetDescription decryptedAdapterDescription =
- (AdapterSetDescription) new AdapterEncryptionService(new Cloner().adapterDescription(adapterDescription)).decrypt();
-
-// String workerUrl = new Utils().getWorkerUrl(adapterDescription);
-// String newUrl = Utils.addUserNameToApi(workerUrl, userName);
-
+ (AdapterSetDescription) new Cloner().adapterDescription(adapterDescription);
WorkerRestClient.invokeSetAdapter(newUrl, decryptedAdapterDescription);
-
-
}
public void detachAdapter(String streamId, String runningInstanceId, String username) throws AdapterException {