From 0136c7e4eacd3d9a95e7f92e9ba50a7a8313ea2b Mon Sep 17 00:00:00 2001 From: zhou-hao Date: Mon, 18 Oct 2021 11:32:03 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BD=BF=E7=94=A8EventBusDeviceOperationBroker?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../standalone/configuration/JetLinksConfiguration.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/jetlinks-standalone/src/main/java/org/jetlinks/community/standalone/configuration/JetLinksConfiguration.java b/jetlinks-standalone/src/main/java/org/jetlinks/community/standalone/configuration/JetLinksConfiguration.java index a8e055b4..5b8bcfec 100644 --- a/jetlinks-standalone/src/main/java/org/jetlinks/community/standalone/configuration/JetLinksConfiguration.java +++ b/jetlinks-standalone/src/main/java/org/jetlinks/community/standalone/configuration/JetLinksConfiguration.java @@ -27,6 +27,7 @@ import org.jetlinks.core.server.monitor.GatewayServerMonitor; import org.jetlinks.core.server.session.DeviceSessionManager; import org.jetlinks.core.spi.ServiceContext; import org.jetlinks.supports.cluster.ClusterDeviceRegistry; +import org.jetlinks.supports.cluster.EventBusDeviceOperationBroker; import org.jetlinks.supports.cluster.redis.RedisClusterManager; import org.jetlinks.supports.config.EventBusStorageManager; import org.jetlinks.supports.event.BrokerEventBus; @@ -84,8 +85,8 @@ public class JetLinksConfiguration { } @Bean - public StandaloneDeviceMessageBroker standaloneDeviceMessageBroker() { - return new StandaloneDeviceMessageBroker(); + public EventBusDeviceOperationBroker eventBusDeviceOperationBroker(ClusterManager clusterManager,EventBus eventBus) { + return new EventBusDeviceOperationBroker(clusterManager.getCurrentServerId(),eventBus); } @Bean