修改 redis配置

修改配置文件指向 新db mongo redis

liquidnet-bus-common/liquidnet-common-service-base/src/main/java/com/liquidnet/service/base/constant/MQConst.java

 package com.liquidnet.service.base.constant;
 
+import org.springframework.beans.factory.annotation.Value;
+
 public class MQConst {
     public static final String QUEUE_MESSAGE_KEY = "message";
 
+    @Value("${spring.profiles.active:prod}")
+    private static String prefix;
+
     public enum AdamQueue {
         SMS_NOTICE("adam:stream:rk.sms.notice", "group.sms.sender", "短信通知"),
 //        SMS_SPREAD("adam:stream:rk.sms.spread", "group.sms.sender", "短信推广"),
@@ -16,7 +21,7 @@ public class MQConst {
         private final String desc;
 
         AdamQueue(String key, String group, String desc) {
-            this.key = key;
+            this.key = "test:".concat(key);
             this.group = group;
             this.desc = desc;
         }
@@ -57,7 +62,7 @@ public class MQConst {
         private final String desc;
 
         KylinQueue(String key, String group, String desc) {
-            this.key = key;
+            this.key = "test:".concat(key);
             this.group = group;
             this.desc = desc;
         }
@@ -98,7 +103,7 @@ public class MQConst {
         private final String desc;
 
         SweetQueue(String key, String group, String desc) {
-            this.key = key;
+            this.key = "test:".concat(key);
             this.group = group;
             this.desc = desc;
         }
@@ -128,7 +133,7 @@ public class MQConst {
         private final String desc;
 
         CandyQueue(String key, String group, String desc) {
-            this.key = key;
+            this.key = "test:".concat(key);
             this.group = group;
             this.desc = desc;
         }
@@ -163,7 +168,7 @@ public class MQConst {
         private final String desc;
 
         SlimeQueue(String key, String group, String desc) {
-            this.key = key;
+            this.key = "test:".concat(key);
             this.group = group;
             this.desc = desc;
         }
@@ -193,7 +198,7 @@ public class MQConst {
         private final String desc;
 
         StoneQueue(String key, String group, String desc) {
-            this.key = key;
+            this.key = "test:".concat(key);
             this.group = group;
             this.desc = desc;
         }
@@ -217,7 +222,7 @@ public class MQConst {
         private final String desc;
 
         SmileQueue(String key, String group, String desc) {
-            this.key = key;
+            this.key = "test:".concat(key);
             this.group = group;
             this.desc = desc;
         }
@@ -242,7 +247,7 @@ public class MQConst {
         private final String desc;
 
         ChimeQueue(String key, String group, String desc) {
-            this.key = key;
+            this.key = "test:".concat(key);
             this.group = group;
             this.desc = desc;
         }
@@ -304,7 +309,7 @@ public class MQConst {
         private final String desc;
 
         GoblinQueue(String key, String group, String desc) {
-            this.key = key;
+            this.key = "test:".concat(key);
             this.group = group;
             this.desc = desc;
         }
@@ -335,7 +340,7 @@ public class MQConst {
         private final String desc;
 
         GalaxyQueue(String key, String group, String desc) {
-            this.key = key;
+            this.key = "test:".concat(key);
             this.group = group;
             this.desc = desc;
         }