dyf/fys-Multi-tenant
1
0
Fork 2
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

在线状态修改优化2

Browse Source
This commit is contained in:
chenyouting
2025-09-13 16:51:56 +08:00
parent 39c8375f08
commit 4004aa1090
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
fys-admin/src/main/java/com/fuyuanshen/global/queue/MqttMessageConsumer.java
View File

@ -68,7 +68,7 @@ public class MqttMessageConsumer {
public void consumeMessages() { public void consumeMessages() {
String queueKey = MqttMessageQueueConstants.MQTT_MESSAGE_QUEUE_KEY; String queueKey = MqttMessageQueueConstants.MQTT_MESSAGE_QUEUE_KEY;
String threadName = Thread.currentThread().getName(); String threadName = Thread.currentThread().getName();
log.info("消息消费者线程 {} 开始监听队列: {}", threadName, queueKey); // log.info("消息消费者线程 {} 开始监听队列: {}", threadName, queueKey);
try { try {
while (!Thread.currentThread().isInterrupted() && !messageConsumerPool.isShutdown()) { while (!Thread.currentThread().isInterrupted() && !messageConsumerPool.isShutdown()) {
@ -81,7 +81,7 @@ public class MqttMessageConsumer {
); );
if (message != null) { if (message != null) {
log.info("线程 {} 从队列中获取到消息，提交到处理线程池: {}", threadName, message); // log.info("线程 {} 从队列中获取到消息，提交到处理线程池: {}", threadName, message);
// 将消息处理任务提交到处理线程池 // 将消息处理任务提交到处理线程池
messageProcessorPool.submit(() -> processMessage(message)); messageProcessorPool.submit(() -> processMessage(message));
} }