From 0e69e77f18ad91168661c0182f22564d99e29fd8 Mon Sep 17 00:00:00 2001 From: zhubaomin <zhubaomin> Date: 星期四, 14 十一月 2024 14:20:29 +0800 Subject: [PATCH] 测试RocketMQ --- pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/ConsumerListener.java | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/ConsumerListener.java b/pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/ConsumerListener.java index 72d46c1..0be11b3 100644 --- a/pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/ConsumerListener.java +++ b/pipIrr-platform/pipIrr-web/pipIrr-web-app/src/main/java/com/dy/pipIrrApp/workOrder/ConsumerListener.java @@ -15,7 +15,7 @@ @Component @RocketMQMessageListener( - topic = "workOrder", + topic = "workOrder2", consumerGroup = "consumer_group", selectorExpression = "*", messageModel = MessageModel.CLUSTERING, -- Gitblit v1.8.0