Skip to content

D
device-new-platform
Commit 9bf0a7d2 authored by 赵啸非's avatar 赵啸非
Browse files
Options

修改redis 过期事件通知

parent fb27c1f4
Hide whitespace changes
Inline Side-by-side
Showing with 3 additions and 1 deletion
device-manager/src/main/java/com/mortals/xhx/daemon/applicationservice/DeviceMsgComsumerStartedService.java
View file @ 9bf0a7d2
...@@ -90,7 +90,9 @@ public class DeviceMsgComsumerStartedService implements IApplicationStartedServi ...@@ -90,7 +90,9 @@ public class DeviceMsgComsumerStartedService implements IApplicationStartedServi
} }
).collect(Collectors.toSet()); ).collect(Collectors.toSet());
mainConsumer.subscribe(topicPartitionInfoSet); mainConsumer.subscribe(topicPartitionInfoSet);
log.info("消费线程订阅topic！：{}", JSON.toJSONString(topicPartitionInfoSet)); topicPartitionInfoSet.stream().forEach(item->{
log.info("消费线程订阅topic：{}", item.getTopic());
});
this.consumersExecutor = Executors.newCachedThreadPool(IotThreadFactory.forName("消费queue线程")); this.consumersExecutor = Executors.newCachedThreadPool(IotThreadFactory.forName("消费queue线程"));
consumersExecutor.submit(() -> { consumersExecutor.submit(() -> {
......
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