[incubator-streampipes] branch dev updated: [hotifx] Force delete adapter when endpoint is not available

[ze...@apache.org]

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 9cb08dc  [hotifx] Force delete adapter when endpoint is not available
9cb08dc is described below

commit 9cb08dcbdc1601ab98c73eaaba0785f5ca8ff38e
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Fri Oct 1 11:51:58 2021 +0200

    [hotifx] Force delete adapter when endpoint is not available
---
 .../container/master/management/AdapterMasterManagement.java     | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/management/AdapterMasterManagement.java b/streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/management/AdapterMasterManagement.java
index 60cdb4e..f2ca003 100644
--- a/streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/management/AdapterMasterManagement.java
+++ b/streampipes-connect-container-master/src/main/java/org/apache/streampipes/connect/container/master/management/AdapterMasterManagement.java
@@ -143,11 +143,18 @@ public class AdapterMasterManagement {
     AdapterDescription ad = adapterStorage.getAdapter(id);
 
     if (isStreamAdapter) {
-      stopStreamAdapter(id, ad.getSelectedEndpointUrl());
+      try {
+        stopStreamAdapter(id, ad.getSelectedEndpointUrl());
+      } catch (AdapterException e) {
+        LOG.info("Could not stop adapter: " + id);
+        LOG.info(e.toString());
+      }
     }
+
     String username = ad.getUserName();
 
     adapterStorage.deleteAdapter(id);
+    LOG.info("Successfully deleted adapter: " + id);
 
     UserService userService = getUserService();
     IPipelineElementDescriptionStorageCache requestor = StorageManager.INSTANCE.getPipelineElementStorage();