整理redis脚本

liquidnet-bus-api/liquidnet-service-dragon-api/src/main/java/com/liquidnet/service/dragon/constant/DragonConstant.java

@@ -251,12 +251,12 @@ public class DragonConstant {
         DRAGON_PAY_GROUP("dragon-pay-group","同步数据-支付-组"),
         DRAGON_REFUND_GROUP ("dragon-refund-group","同步数据-退款-组"),
         //三方异步通知相关队列
-        DRAGON_PAY_NOTIFY_KEY("dragon-pay-notify-key","支付异步通知"),
+        DRAGON_PAY_NOTIFY_KEY("dragon:stream:dragon-pay-notify-key","支付异步通知"),
         DRAGON_PAY_NOTIFY_GROUP ("dragon-pay-notify-group","支付异步通知-组"),
         //商户通知相关队列
-        PAY_MCH_NOTIFY_KEY("pay-mch-notify-key","商户异步通知"),
+        PAY_MCH_NOTIFY_KEY("dragon:stream:pay-mch-notify-key","商户异步通知"),
         PAY_MCH_NOTIFY_GROUP ("pay-mch-notify-group","商户异步通知-组"),
-        PAY_MCH_NOTIFY_ERROR_KEY("pay-mch-notify-error-key","商户异步通知失败"),
+        PAY_MCH_NOTIFY_ERROR_KEY("dragon:stream:pay-mch-notify-error-key","商户异步通知失败"),
         PAY_MCH_NOTIFY_ERROR_GROUP ("pay-mch-notify-error-group","商户异步通知失败-组");
         private String code;
         private String message;

liquidnet-bus-service/liquidnet-service-dragon/liquidnet-service-dragon-impl/docu/redis_queue_create.sql

 -- pay
 XADD dragon:stream:dragon-pay * 0 0
-XADD dragon-pay-notify-key * 0 0
-XADD pay-mch-notify-key * 0 0
-XADD pay-mch-notify-error-key * 0 0
+XADD dragon:stream:dragon-pay-notify-key * 0 0
+XADD dragon:stream:pay-mch-notify-key * 0 0
+XADD dragon:stream:pay-mch-notify-error-key * 0 0
 XGROUP CREATE dragon:stream:dragon-pay dragon-pay-group 0
 XGROUP CREATE dragon-pay-notify-key dragon-pay-notify-group 0
 XGROUP CREATE pay-mch-notify-key pay-mch-notify-group 0