优化配置

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<EventBroker> provider,
                                    ObjectProvider<Scheduler> scheduler) {