From 0bf1099fdbe12c281cc8c9a30c4ab642df2c58c7 Mon Sep 17 00:00:00 2001
From: liyongde <1419499670@qq.com>
Date: Mon, 20 Jul 2026 13:41:52 +0800
Subject: [PATCH] =?UTF-8?q?feat=EF=BC=9A=E6=B6=88=E8=B4=B9=E8=80=85?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../mq/consumer/TaskStatusChangeConsumer.java | 24 +++++++++++++++++++
 1 file changed, 24 insertions(+)
 create mode 100644 nl-module-wms/nl-module-wms-server/src/main/java/cn/code/nl/module/wms/mq/consumer/TaskStatusChangeConsumer.java

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