diff --git a/nl-module-wms/nl-module-wms-server/src/main/java/cn/code/nl/module/wms/mq/consumer/TaskStatusChangeConsumer.java b/nl-module-wms/nl-module-wms-server/src/main/java/cn/code/nl/module/wms/mq/consumer/TaskStatusChangeConsumer.java new file mode 100644 index 00000000..e7634380 --- /dev/null +++ b/nl-module-wms/nl-module-wms-server/src/main/java/cn/code/nl/module/wms/mq/consumer/TaskStatusChangeConsumer.java @@ -0,0 +1,24 @@ +package cn.code.nl.module.wms.mq.consumer; + +import lombok.extern.slf4j.Slf4j; +import org.apache.rocketmq.spring.annotation.RocketMQMessageListener; +import org.apache.rocketmq.spring.core.RocketMQListener; +import org.springframework.stereotype.Component; + +/** + * 监听任务状态变更 + * @Author: liyongde + * @Date: 2026/7/20 10:28 + */ +@Slf4j +@Component +@RocketMQMessageListener(topic = "${rocketmq.topic.wms-task-status-change}", + consumerGroup = "${rocketmq.push-consumer.group.wms-task-status-change}", + namespace = "${rocketmq.push-consumer.namespace}") +public class TaskStatusChangeConsumer implements RocketMQListener { + + @Override + public void onMessage(Object o) { + + } +}