Skip to content

A
amos-boot-biz
Commit 6fa72b5d authored by tianbo's avatar tianbo
Browse files
Options

feat(module-jg): 订阅安全追溯问题主题时增加日志输出

- 在 SafetyProblemTopicMessage 类的 init 方法中添加了日志输出 - 记录订阅的安全追溯问题主题名称
parent 6dc163ef
Show whitespace changes
Inline Side-by-side
Showing with 1 addition and 0 deletions
amos-boot-system-tzs/amos-boot-module-jg/amos-boot-module-jg-biz/src/main/java/com/yeejoin/amos/boot/module/jg/biz/listener/SafetyProblemTopicMessage.java
View file @ 6fa72b5d
...@@ -74,6 +74,7 @@ public class SafetyProblemTopicMessage extends EmqxListener { ...@@ -74,6 +74,7 @@ public class SafetyProblemTopicMessage extends EmqxListener {
@PostConstruct @PostConstruct
void init() throws Exception { void init() throws Exception {
log.info("订阅安全追溯问题主题:{}", buildTopic(problemEventTopic));
emqKeeper.subscript(buildTopic(problemEventTopic), 2, this); emqKeeper.subscript(buildTopic(problemEventTopic), 2, this);
executorService = Executors.newFixedThreadPool(threadNumber); executorService = Executors.newFixedThreadPool(threadNumber);
for (int i = 0; i < threadNumber; i++) { for (int i = 0; i < threadNumber; i++) {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment