使用EventBusDeviceOperationBroker

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