From 99333d7c026a2dc1e29806e7e76bfe46db6469a5 Mon Sep 17 00:00:00 2001 From: Barry Nouwt Date: Fri, 1 Mar 2024 09:47:23 +0100 Subject: [PATCH] Restore notify to make sure we do not break anything. --- .../messaging/LocalSmartConnectorConnectionManager.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/smart-connector/src/main/java/eu/knowledge/engine/smartconnector/runtime/messaging/LocalSmartConnectorConnectionManager.java b/smart-connector/src/main/java/eu/knowledge/engine/smartconnector/runtime/messaging/LocalSmartConnectorConnectionManager.java index 8f75efad..9e595e37 100644 --- a/smart-connector/src/main/java/eu/knowledge/engine/smartconnector/runtime/messaging/LocalSmartConnectorConnectionManager.java +++ b/smart-connector/src/main/java/eu/knowledge/engine/smartconnector/runtime/messaging/LocalSmartConnectorConnectionManager.java @@ -53,9 +53,9 @@ public void smartConnectorAdded(RuntimeSmartConnector smartConnector) { LocalSmartConnectorConnection connection = new LocalSmartConnectorConnection(messageDispatcher, endpoint); this.localSmartConnectorConnections.put(endpoint.getKnowledgeBaseId(), connection); connection.start(); - if (messageDispatcher.runsInDistributedMode()) { this.messageDispatcher.getRemoteSmartConnectorConnectionsManager().notifyChangedLocalSmartConnectors(); + this.messageDispatcher.notifySmartConnectorsChanged(); } } @@ -68,6 +68,7 @@ public void smartConnectorRemoved(RuntimeSmartConnector smartConnector) { if (messageDispatcher.runsInDistributedMode()) { this.messageDispatcher.getRemoteSmartConnectorConnectionsManager().notifyChangedLocalSmartConnectors(); + this.messageDispatcher.notifySmartConnectorsChanged(); } }