修复队列

carbon-h5/carbon-h5-service/src/main/java/com/hcloud/microserver/h5/config/mq/MQConstant.java

@@ -13,7 +13,7 @@ public final class MQConstant {
     //TTL QUEUE
     public static final String DEFAULT_DEAD_LETTER_QUEUE_NAME = "zy.dead.letter.queue";
 
-    //DLX repeat QUEUE 死信转发队列
+    //DLX repeat QUEUE 私信转发队列
     public static final String DEFAULT_REPEAT_TRADE_QUEUE_NAME = "zy.repeat.trade.queue";
 
     //Hello 测试消息队列名称

carbon-h5/carbon-h5-service/src/main/java/com/hcloud/microserver/h5/config/mq/MessageService.java

@@ -39,7 +39,7 @@ public class MessageService implements IMessageService {
      */
     @Override
     public void send(String queueName, String message, long times) {
-        //消息发送到死信队列上，当消息超时时，会发生到转发队列上，转发队列根据下面封装的queueName，把消息转发的指定队列上
+        //消息发送到私信队列上，当消息超时时，会发生到转发队列上，转发队列根据下面封装的queueName，把消息转发的指定队列上
         //发送前，把消息进行封装，转发时应转发到指定 queueName 队列上
         DLXMessage dlxMessage = new DLXMessage(MQConstant.DEFAULT_EXCHANGE, queueName, message, times);
         MessagePostProcessor processor = new MessagePostProcessor() {

carbon-h5/carbon-h5-service/src/main/java/com/hcloud/microserver/h5/config/mq/QueueConfiguration.java

@@ -49,7 +49,7 @@ public class QueueConfiguration {
         return BindingBuilder.bind(repeatTradeQueue()).to(defaultExchange()).with(MQConstant.DEFAULT_REPEAT_TRADE_QUEUE_NAME);
     }
 
-    //死信队列  -- 消息在死信队列上堆积，消息超时时，会把消息转发到转发队列，转发队列根据消息内容再把转发到指定的队列上
+    //私信队列  -- 消息在私信队列上堆积，消息超时时，会把消息转发到转发队列，转发队列根据消息内容再把转发到指定的队列上
     @Bean
     public Queue deadLetterQueue() {
         Map<String, Object> arguments = new HashMap<>();
@@ -58,7 +58,7 @@ public class QueueConfiguration {
         Queue queue = new Queue(MQConstant.DEFAULT_DEAD_LETTER_QUEUE_NAME,true,false,false,arguments);
         return queue;
     }
-    //绑定死信队列
+    //绑定私信队列
     @Bean
     public Binding  deadLetterBinding() {
         return BindingBuilder.bind(deadLetterQueue()).to(defaultExchange()).with(MQConstant.DEFAULT_DEAD_LETTER_QUEUE_NAME);

carbon-h5/carbon-h5-service/src/main/java/com/hcloud/microserver/h5/config/mq/service/DLXMessage.java

@@ -3,7 +3,7 @@ package com.hcloud.microserver.h5.config.mq.service;
 import java.io.Serializable;
 
 /**
- * rabbit 死信消息载体
+ * rabbit 私信消息载体
  */
 public class DLXMessage implements Serializable {