任务接口

themis-mq/src/main/java/com/qmth/themis/mq/listener/RocketUserLogConsumer.java

@@ -89,7 +89,7 @@ public class RocketUserLogConsumer implements MessageListenerConcurrently {
                     mqDto.setAck(SystemConstant.STANDARD_ACK_TYPE);
                     TMRocketMessage tmRocketMessage = gson.fromJson(gson.toJson(mqDto), TMRocketMessage.class);
                     tmRocketMessageService.saveOrUpdate(tmRocketMessage);
-//                    redisUtil.deleteMqTopicList(mqTopic, mqDto.getId());
+                    redisUtil.deleteMqTopicList(mqTopic, mqDto.getId());
                     return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
                 } else {
                     log.info(":{}-:{} 消息ack未确认，重发", threadId, threadName);