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(); } }