消费NFT注掉已迁移队列

liquidnet-bus-config/liquidnet-config/liquidnet-service-consumer-base.yml

@@ -59,15 +59,14 @@ spring:
     include: common-service #这里加载management相关公共配置
   redis:
     database: ${liquidnet.redis.kylin.database}
-    dbs: ${liquidnet.redis.kylin.dbs}
     port: ${liquidnet.redis.kylin.port}
     host: ${liquidnet.redis.kylin.host}
     password: ${liquidnet.redis.kylin.password}
     lettuce:
       pool:
-        max-active: 20
+        max-active: 60
         max-wait: -1
-        max-idle: 8
+        max-idle: 48
         min-idle: 0
   data:
     mongodb:

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/config/ConsumerCommonBizRedisStreamConfig.java

@@ -46,7 +46,7 @@ public class ConsumerCommonBizRedisStreamConfig extends RedisStreamConfig {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.KylinQueue stream = MQConst.KylinQueue.SMS_NOTICE;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
-        for (int i = 0; i < 2; i++) {
+        for (int i = 0; i < 3; i++) {
             StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
             subscriptionList.add(listenerContainer.receiveAutoAck(
                     Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),