修改 redis队列消费指定 db

liquidnet-bus-common/liquidnet-common-cache/liquidnet-common-cache-redis/src/main/java/com.liquidnet.common.cache/redis/util/RedisUtil.java

@@ -4,6 +4,7 @@ import com.liquidnet.common.cache.redis.config.AbstractRedisConfig;
 import com.liquidnet.common.cache.redis.config.RedisConfig;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
 
 /**
@@ -20,10 +21,17 @@ import org.springframework.stereotype.Component;
 public final class RedisUtil extends AbstractRedisUtil{
     @Autowired
     private RedisConfig redisConfig;
+    @Value("${spring.profiles.active:prod}")
+    private String prefix;
+
+    @Override
+    public String fillingKey(String key) {
+        return prefix.equals("prod") ? key : prefix.concat(":").concat(key);
+    }
 
     @Override
     public int getDbs() {
-//        log.info("redisConfig.totalDbs===",redisConfig.totalDbs);
+        log.info("redisConfig.totalDbs:{},prefix:{}===", redisConfig.totalDbs, prefix);
         return redisConfig.totalDbs;
     }