fix for bug #107

SoftwareAG · Apr 30, 2024 · c26cce7 · c26cce7
1 parent c46ca3f
commit c26cce7
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...mapping-service/src/main/java/dynamic/mapping/connector/core/client/AConnectorClient.java b/...mapping-service/src/main/java/dynamic/mapping/connector/core/client/AConnectorClient.java
@@ -381,8 +381,10 @@ public void upsertActiveSubscription(Mapping mapping) {
                 if (!getActiveSubscriptions().containsKey(mapping.subscriptionTopic)) {
                     getActiveSubscriptions().put(mapping.subscriptionTopic, new MutableInt(0));
                 }
-                if (!getMappingsDeployed().containsKey(mapping.ident)) {
+                if (mapping.active) {
                     getMappingsDeployed().put(mapping.ident, mapping);
+                } else {
+                    getMappingsDeployed().remove(mapping.ident);
                 }
                 MutableInt updatedMappingSubs = getActiveSubscriptions()
                         .get(mapping.subscriptionTopic);