名称修改

order-application-service/src/main/java/cn/freemud/amp/config/DlPayQueryMqConfig.java

@@ -16,7 +16,7 @@ public class DlPayQueryMqConfig {
      * 消费队列
      */
     public static final String KGD_PAY_QUERY_QUEUE = "kgd_pay_query_queue";
-    public static final String KGD_PAYMENT_QUERY_KEY = "kgd_pay_query_key";
+    public static final String KGD_PAY_QUERY_KEY = "kgd_pay_query_key";
 
     /**
      * 死信队列
@@ -49,7 +49,7 @@ public class DlPayQueryMqConfig {
      */
     @Bean("bindingPayQueueChange")
     Binding bindingPaymentChange(@Qualifier("payQueueName") Queue queue, @Qualifier("dlPayMqTopicExchange") Exchange topicExchange) {
-        return BindingBuilder.bind(queue).to(topicExchange).with(KGD_PAYMENT_QUERY_KEY).noargs();
+        return BindingBuilder.bind(queue).to(topicExchange).with(KGD_PAY_QUERY_KEY).noargs();
     }
 
 
@@ -59,7 +59,7 @@ public class DlPayQueryMqConfig {
         // DLX，dead letter发送到的exchange
         delayQueueParams.put("x-dead-letter-exchange", TopicExchangeConfig.EXCHANGE_NAME);
         // dead letter携带的routing key
-        delayQueueParams.put("x-dead-letter-routing-key", KGD_PAYMENT_QUERY_KEY);
+        delayQueueParams.put("x-dead-letter-routing-key", KGD_PAY_QUERY_KEY);
         //时间
         //delayQueueParams.put("x-message-ttl", 20*1000);
         return QueueBuilder.durable(KGD_PAY_QUERY_DL_QUEUE).withArguments(delayQueueParams).build();
@@ -69,7 +69,7 @@ public class DlPayQueryMqConfig {
     Binding bindingPaymentDlChange(@Qualifier("payChangeDlQueue") Queue queue, @Qualifier("dlPayMqTopicExchange") Exchange topicExchange) {
         Map<String, Object> args = new HashMap<>(2);
         args.put("x-dead-letter-exchange", TopicExchangeConfig.EXCHANGE_NAME);
-        args.put("x-dead-letter-routing-key", KGD_PAYMENT_QUERY_KEY);
+        args.put("x-dead-letter-routing-key", KGD_PAY_QUERY_KEY);
         return BindingBuilder.bind(queue).to(topicExchange).with(KGD_PAY_QUERY_DL_KEY).and(args);
     }