MQ 消息队列名修改

2024-01-29 17:03:10 +08:00
parent 7386f4427d
commit 533b54a768
1 changed files with 2 additions and 1 deletions
--- a/src/main/java/com/ai/da/common/RabbitMQ/MQConfig.java
+++ b/src/main/java/com/ai/da/common/RabbitMQ/MQConfig.java
@@ -16,7 +16,8 @@ import org.springframework.beans.factory.annotation.Value;
 public class MQConfig {

    public static final String GENERATE_EXCHANGE_FANOUT = "generate-exchange";
-    public static final String GENERATE_QUEUE = "generate-queue-prod";
+//    public static final String GENERATE_QUEUE = "generate-queue-prod";
+    public static final String GENERATE_QUEUE = "generate-queue-test";

    public MQConfig() {
    }