You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@aries.apache.org by am...@apache.org on 2026/05/17 08:47:34 UTC
(aries-rsa) 04/05: Ensure executor shutdown in TopologyManagerImport.stop()
This is an automated email from the ASF dual-hosted git repository.
amichair pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/aries-rsa.git
commit 42a6a910abbabac67ca3a31e451fa3a1f2f163f4
Author: Amichai Rothman <am...@apache.org>
AuthorDate: Mon Mar 30 00:16:00 2026 +0300
Ensure executor shutdown in TopologyManagerImport.stop()
---
.../apache/aries/rsa/topologymanager/importer/TopologyManagerImport.java | 1 +
1 file changed, 1 insertion(+)
diff --git a/topology-manager/src/main/java/org/apache/aries/rsa/topologymanager/importer/TopologyManagerImport.java b/topology-manager/src/main/java/org/apache/aries/rsa/topologymanager/importer/TopologyManagerImport.java
index 873f6415..07cd0e8e 100644
--- a/topology-manager/src/main/java/org/apache/aries/rsa/topologymanager/importer/TopologyManagerImport.java
+++ b/topology-manager/src/main/java/org/apache/aries/rsa/topologymanager/importer/TopologyManagerImport.java
@@ -91,6 +91,7 @@ public class TopologyManagerImport implements EndpointEventListener, RemoteServi
LOG.info("Interrupted while waiting for {} to terminate", execService);
Thread.currentThread().interrupt();
}
+ execService.shutdownNow();
// close all imports
importPossibilities.clear();
importedServices.allValues().forEach(this::unimportRegistration);