提交 017c9f26 编写于 作者: fengmin's avatar fengmin

实时更新规则引擎订阅主题二

上级 571cced1
...@@ -80,7 +80,7 @@ public class RocktcermqCustmerRunner implements ApplicationRunner { ...@@ -80,7 +80,7 @@ public class RocktcermqCustmerRunner implements ApplicationRunner {
dataMap.put(ruleEngine.getEngineId(), consumer); dataMap.put(ruleEngine.getEngineId(), consumer);
consumer.subscribe((String) map.get(TOPIC.getProperty()), "*"); consumer.subscribe((String) map.get(TOPIC.getProperty()), "*");
consumer.start(); consumer.start();
log.info("ruleEngineConsumer 创建成功 groupName={}, topics={}, namesrvAddr={}", ruleEngine.getEngineId(), ruleEngine.getModelId(), namesrvAddr); log.info("ruleEngineConsumer 创建成功 groupName={}, topics={}, namesrvAddr={}", ruleEngine.getEngineId(),map.get(TOPIC.getProperty()), namesrvAddr);
} catch (MQClientException e) { } catch (MQClientException e) {
e.printStackTrace(); e.printStackTrace();
log.error("ruleEngineConsumer 创建失败!"); log.error("ruleEngineConsumer 创建失败!");
......
Markdown 格式
0% or
您添加了 0 到此讨论。请谨慎行事。
先完成此消息的编辑!
想要评论请 注册