feat：消费者

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) {
+
+    }
+}