From 2c84fee3324a4422b72fb9a9daecf625fdfb9bcb Mon Sep 17 00:00:00 2001 From: zhouhao Date: Mon, 26 Sep 2022 17:38:29 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E9=85=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../configure/cluster/ClusterConfiguration.java | 11 ----------- 1 file changed, 11 deletions(-) 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) {