feat:[1005527]公众号-关注后延时推送

pcloud-common-core/src/main/java/com/pcloud/common/core/mq/MQExchangeConstants.java

@@ -22,12 +22,12 @@ public class MQExchangeConstants {
      */
     public static final String BOOK_DELAY_ROUTING_KEY = "book.routingkey.delay";
     /**
-     * book 延时队列交换机
+     * wechatgroup 延时队列交换机
      */
     public static final String WECHATGROUP_DELAYED_EXCHANGE = "wechatgroup.exchange.delay";
 
     /**
-     * book 延时队列 routing key
+     * wechatgroup 延时队列 routing key
      */
     public static final String WECHATGROUP_DELAY_ROUTING_KEY = "wechatgroup.routingkey.delay";
 
@@ -40,5 +40,14 @@ public class MQExchangeConstants {
      * trade 延时队列 routing key
      */
     public static final String TRADE_DELAY_ROUTING_KEY = "trade.routingkey.delay";
+    /**
+     *channel 延时队列交换机
+     */
+    public static final String CHANNEL_DELAYED_EXCHANGE = "channel.exchange.delay";
+
+    /**
+     * channel 延时队列 routing key
+     */
+    public static final String CHANNEL_DELAY_ROUTING_KEY = "channel.routingkey.delay";
 
 }

pcloud-common-core/src/main/java/com/pcloud/common/core/mq/MQQueueConstants.java

@@ -22,4 +22,9 @@ public class MQQueueConstants {
      */
 
     public static final String TRADE_IMMEDIATE_QUEUE_FOR_DELAY = "trade." + IMMEDIATE_QUEUE_FOR_DELAY;
+    /**
+     * channel 延时队列
+     */
+
+    public static final String CHANNEL_IMMEDIATE_QUEUE_FOR_DELAY = "channel." + IMMEDIATE_QUEUE_FOR_DELAY;
 }