diff --git a/sf-vertx/src/main/java/com/sf/vertx/handle/AppConfigHandler.java b/sf-vertx/src/main/java/com/sf/vertx/handle/AppConfigHandler.java index cd9f80b..cd3a8bc 100644 --- a/sf-vertx/src/main/java/com/sf/vertx/handle/AppConfigHandler.java +++ b/sf-vertx/src/main/java/com/sf/vertx/handle/AppConfigHandler.java @@ -373,6 +373,7 @@ public class AppConfigHandler { initConnectionCircuitBreaker(); createVertxRouter(); + consumerClusterEventMsg(); } private static Config hazelcastConfig(SacVertxConfig sacVertxConfig) { @@ -415,23 +416,7 @@ public class AppConfigHandler { log.info("hazelcastClusterManager create success"); initConnectionCircuitBreaker(); createVertxRouter(); - // 订阅消息 - VERTX.eventBus().consumer("sac_cluster_event", message -> { - if (message.body() != null) { - ClusterEventMsg msg = JSONObject.parseObject(message.body().toString(), ClusterEventMsg.class); - log.info("Received message: {}", msg); - // message.reply("我是返回数据===" + message.body()); - if (msg.getType() == 1) { - if (msg.getOperation() == 1) { - // 初始化AppConfig本地缓存 - AppConfigHandler.initAppConfig(msg.getAppCode(), true); - } else if (msg.getOperation() == 3) { - // 禁用本地缓存 - AppConfigHandler.addDisabledAppcode(msg.getAppCode()); - } - } - } - }); + consumerClusterEventMsg(); } else { res.cause().printStackTrace(); log.info("hazelcastClusterManager create failure"); @@ -439,6 +424,26 @@ public class AppConfigHandler { }); } + private static void consumerClusterEventMsg() { + // 订阅消息 + VERTX.eventBus().consumer("sac_cluster_event", message -> { + if (message.body() != null) { + ClusterEventMsg msg = JSONObject.parseObject(message.body().toString(), ClusterEventMsg.class); + log.info("Received message: {}", msg); + // message.reply("我是返回数据===" + message.body()); + if (msg.getType() == 1) { + if (msg.getOperation() == 1) { + // 初始化AppConfig本地缓存 + AppConfigHandler.initAppConfig(msg.getAppCode(), true); + } else if (msg.getOperation() == 3) { + // 禁用本地缓存 + AppConfigHandler.addDisabledAppcode(msg.getAppCode()); + } + } + } + }); + } + /*** * 发布消息,订阅消息 *