diff --git a/jetlinks-components/configure-component/src/main/java/org/jetlinks/community/configure/cluster/ClusterConfiguration.java b/jetlinks-components/configure-component/src/main/java/org/jetlinks/community/configure/cluster/ClusterConfiguration.java index 26350b19..ccb43911 100644 --- a/jetlinks-components/configure-component/src/main/java/org/jetlinks/community/configure/cluster/ClusterConfiguration.java +++ b/jetlinks-components/configure-component/src/main/java/org/jetlinks/community/configure/cluster/ClusterConfiguration.java @@ -2,9 +2,6 @@ package org.jetlinks.community.configure.cluster; import io.scalecube.cluster.ClusterConfig; import io.scalecube.net.Address; -import io.scalecube.services.Microservices; -import io.scalecube.services.ServiceInfo; -import io.scalecube.services.ServiceProvider; import io.scalecube.services.transport.rsocket.RSocketClientTransportFactory; import io.scalecube.services.transport.rsocket.RSocketServerTransportFactory; import io.scalecube.services.transport.rsocket.RSocketServiceTransport; @@ -15,11 +12,8 @@ import org.jetlinks.supports.cluster.redis.RedisClusterManager; import org.jetlinks.supports.config.EventBusStorageManager; import org.jetlinks.supports.event.BrokerEventBus; import org.jetlinks.supports.event.EventBroker; -import org.jetlinks.supports.scalecube.DynamicServiceRegistry; import org.jetlinks.supports.scalecube.ExtendedCluster; import org.jetlinks.supports.scalecube.ExtendedClusterImpl; -import org.jetlinks.supports.scalecube.ExtendedServiceDiscoveryImpl; -import org.jetlinks.supports.scalecube.event.ScalecubeEventBusBroker; import org.jetlinks.supports.scalecube.rpc.ScalecubeRpcManager; import org.nustaq.serialization.FSTConfiguration; import org.springframework.beans.factory.ObjectProvider; @@ -75,11 +69,6 @@ public class ClusterConfiguration { return impl; } - @Bean - public EventBroker eventBroker(ExtendedCluster cluster) { - return new ScalecubeEventBusBroker(cluster); - } - @Bean public BrokerEventBus eventBus(ObjectProvider provider, ObjectProvider scheduler) {