Merge branch 'hjc_init_consumer' into dev_rc_xuper_op

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-goblin/src/main/java/com/liquidnet/service/consumer/goblin/config/ConsumerGoblinOrderAGRedisStreamConfig.java

@@ -27,7 +27,7 @@ public class ConsumerGoblinOrderAGRedisStreamConfig extends RedisStreamConfig {
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlGOrderAgain(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_ORDER_AGAIN;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-goblin/src/main/java/com/liquidnet/service/consumer/goblin/config/ConsumerGoblinOrderCPRedisStreamConfig.java

@@ -27,7 +27,7 @@ public class ConsumerGoblinOrderCPRedisStreamConfig extends RedisStreamConfig {
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlGCP(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_ORDER_CREATE_PAY;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerKylinSqlOptOrderCloseRedisStreamConfig.java

@@ -29,7 +29,7 @@ public class ConsumerKylinSqlOptOrderCloseRedisStreamConfig extends RedisStreamC
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlOC(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.KylinQueue stream = MQConst.KylinQueue.SQL_ORDER_CLOSE;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerKylinSqlOrderPayRedisStreamConfig.java

@@ -30,7 +30,7 @@ public class ConsumerKylinSqlOrderPayRedisStreamConfig extends RedisStreamConfig
 
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlOP(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.KylinQueue stream = MQConst.KylinQueue.SQL_ORDER_PAY;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/config/ConsumerKylinSqlOrderRefundRedisStreamConfig.java

@@ -30,7 +30,7 @@ public class ConsumerKylinSqlOrderRefundRedisStreamConfig extends RedisStreamCon
 
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlOR(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.KylinQueue stream = MQConst.KylinQueue.SQL_ORDER_REFUND;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/config/ConsumerGoblinSelfMarketRedisStreamConfig.java

@@ -27,7 +27,7 @@ public class ConsumerGoblinSelfMarketRedisStreamConfig extends RedisStreamConfig
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlSelfMarket(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_SELF_MARKET;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/config/ConsumerGoblinShopCartStreamConfig.java

@@ -27,7 +27,7 @@ public class ConsumerGoblinShopCartStreamConfig extends RedisStreamConfig {
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlShopCar(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_SHOP_CART;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/config/ConsumerGoblinStoneMarketRedisStreamConfig.java

@@ -27,7 +27,7 @@ public class ConsumerGoblinStoneMarketRedisStreamConfig extends RedisStreamConfi
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlStoneMarket(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_STORE_MARKET;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/config/ConsumerGoblinStoreOrderRedisStreamConfig.java

@@ -27,7 +27,7 @@ public class ConsumerGoblinStoreOrderRedisStreamConfig extends RedisStreamConfig
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlStoreOrder(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_STORE_ORDER_OPERA;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/config/ConsumerGoblinUserOrderRedisStreamConfig.java

@@ -27,7 +27,7 @@ public class ConsumerGoblinUserOrderRedisStreamConfig extends RedisStreamConfig
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlUserOrder(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_USER_ORDER_OPERA;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/config/ConsumerGoblinXlsRedisStreamConfig.java

@@ -27,7 +27,7 @@ public class ConsumerGoblinXlsRedisStreamConfig extends RedisStreamConfig {
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlXls(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_XLS_OPERA;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/config/ConsumerKylinOptTransferOverTimeRedisStreamConfig.java

@@ -29,7 +29,7 @@ public class ConsumerKylinOptTransferOverTimeRedisStreamConfig extends RedisStre
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlOverTime(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.KylinQueue stream = SQL_TRANSFER_OVERTIME;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/config/ConsumerKylinOrderRefundExpressRedisStreamConfig.java

@@ -29,7 +29,7 @@ public class ConsumerKylinOrderRefundExpressRedisStreamConfig extends RedisStrea
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlOrderRefundExpress(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.KylinQueue stream = SQL_ORDER_REFUND_EXPRESS;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/config/ConsumerKylinSmsSenderRedisStreamConfig.java

@@ -27,7 +27,7 @@ public class ConsumerKylinSmsSenderRedisStreamConfig extends RedisStreamConfig {
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlURegister(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.AdamQueue stream = MQConst.AdamQueue.SMS_NOTICE;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/config/ConsumerKylinSqlOrderWithdrawRedisStreamConfig.java

@@ -29,7 +29,7 @@ public class ConsumerKylinSqlOrderWithdrawRedisStreamConfig extends RedisStreamC
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlWithdraw(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.KylinQueue stream = SQL_ORDER_WITHDRAW;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/config/ConsumerKylinSqlPerformanceLackRedisStreamConfig.java

@@ -29,7 +29,7 @@ public class ConsumerKylinSqlPerformanceLackRedisStreamConfig extends RedisStrea
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlPLack(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.KylinQueue stream = SQL_PERFORMANCE_LACK;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/config/ConsumerKylinSqlStationRedisStreamConfig.java

@@ -30,7 +30,7 @@ public class ConsumerKylinSqlStationRedisStreamConfig extends RedisStreamConfig
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlStation(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.KylinQueue stream = SQL_STATION;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/config/ConsumerKylinSqlTransferRedisStreamConfig.java

@@ -29,7 +29,7 @@ public class ConsumerKylinSqlTransferRedisStreamConfig extends RedisStreamConfig
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlTransfer(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.KylinQueue stream = SQL_TRANSFER;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/config/ConsumerKylinSqlTransferResultRedisStreamConfig.java

@@ -29,7 +29,7 @@ public class ConsumerKylinSqlTransferResultRedisStreamConfig extends RedisStream
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlTransferResult(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.KylinQueue stream = SQL_TRANSFER_RESULT;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/config/ConsumerSlimeFieldRedisStreamConfig.java

@@ -28,7 +28,7 @@ public class ConsumerSlimeFieldRedisStreamConfig extends RedisStreamConfig {
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlField(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.SlimeQueue stream = MQConst.SlimeQueue.SQL_SLIME_FIELD;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/config/ConsumerSlimeLineRedisStreamConfig.java

@@ -27,7 +27,7 @@ public class ConsumerSlimeLineRedisStreamConfig extends RedisStreamConfig {
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlLine(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.SlimeQueue stream = MQConst.SlimeQueue.SQL_SLIME_LINE;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
@@ -42,29 +42,29 @@ public class ConsumerSlimeLineRedisStreamConfig extends RedisStreamConfig {
         return subscriptionList;
     }
 
-    /**
-     * 验票更新
-     *
-     * @param listenerContainer
-     * @param t
-     * @return
-     */
-    private Subscription receiveTransferResult(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
-        return listenerContainer.receiveAutoAck(Consumer.from(MQConst.SlimeQueue.SQL_SLIME_LINE.getGroup(), getConsumerName(MQConst.SlimeQueue.SQL_SLIME_LINE.name() + t)),
-                StreamOffset.create(MQConst.SlimeQueue.SQL_SLIME_LINE.getKey(), ReadOffset.lastConsumed()), consumerSlimeLineRdsReceiver);
-    }
-
-    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
-
-    /* -------------------------------------------------------- ｜ 验票更新 */
-
-    @Bean
-    public Subscription subscriptionReceiveLine0(RedisConnectionFactory factory) {
-        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveTransferResult(listenerContainer, 0);
-        listenerContainer.start();
-        return subscription;
-    }
+//    /**
+//     * 验票更新
+//     *
+//     * @param listenerContainer
+//     * @param t
+//     * @return
+//     */
+//    private Subscription receiveTransferResult(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
+//        return listenerContainer.receiveAutoAck(Consumer.from(MQConst.SlimeQueue.SQL_SLIME_LINE.getGroup(), getConsumerName(MQConst.SlimeQueue.SQL_SLIME_LINE.name() + t)),
+//                StreamOffset.create(MQConst.SlimeQueue.SQL_SLIME_LINE.getKey(), ReadOffset.lastConsumed()), consumerSlimeLineRdsReceiver);
+//    }
+//
+//    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
+//
+//    /* -------------------------------------------------------- ｜ 验票更新 */
+//
+//    @Bean
+//    public Subscription subscriptionReceiveLine0(RedisConnectionFactory factory) {
+//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+//        var subscription = receiveTransferResult(listenerContainer, 0);
+//        listenerContainer.start();
+//        return subscription;
+//    }
 
 //    @Bean
 //    public Subscription subscriptionReceiveLine1(RedisConnectionFactory factory) {

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/config/ConsumerSlimePerformanceInsertRedisStreamConfig.java

@@ -27,7 +27,7 @@ public class ConsumerSlimePerformanceInsertRedisStreamConfig extends RedisStream
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlSlimeInsert(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.SlimeQueue stream = MQConst.SlimeQueue.SQL_SLIME_PERFORMANCE_INSERT;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/config/ConsumerSlimePerformanceRedisStreamConfig.java

@@ -27,7 +27,7 @@ public class ConsumerSlimePerformanceRedisStreamConfig extends RedisStreamConfig
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlReceiveTransfer(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.SlimeQueue stream = MQConst.SlimeQueue.SQL_SLIME_PERFORMANCE_UPDATE;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/config/ConsumerSlimeSponsorRedisStreamConfig.java

@@ -27,7 +27,7 @@ public class ConsumerSlimeSponsorRedisStreamConfig extends RedisStreamConfig {
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlSlimeSponsor(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.SlimeQueue stream = MQConst.SlimeQueue.SQL_SLIME_SPONSOR;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/config/ConsumerSlimeStep2RedisStreamConfig.java

@@ -27,7 +27,7 @@ public class ConsumerSlimeStep2RedisStreamConfig extends RedisStreamConfig {
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlSlimeStep2(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.SlimeQueue stream = MQConst.SlimeQueue.SQL_SLIME_STEP2;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/config/ConsumerSlimeTicketRedisStreamConfig.java

@@ -27,7 +27,7 @@ public class ConsumerSlimeTicketRedisStreamConfig extends RedisStreamConfig {
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlSlimeTicketU(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.SlimeQueue stream = MQConst.SlimeQueue.SQL_SLIME_TICKET_UPDATE;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-stone/src/main/java/com/liquidnet/servce/consumer/stone/service/config/ConsumerStoneLogsRedisStreamConfig.java

@@ -27,7 +27,7 @@ public class ConsumerStoneLogsRedisStreamConfig extends RedisStreamConfig {
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlIL(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.StoneQueue stream = MQConst.StoneQueue.STONE_INSERT_LOGS;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-stone/src/main/java/com/liquidnet/servce/consumer/stone/service/config/ConsumerStoneOrderRedisStreamConfig.java

@@ -27,7 +27,7 @@ public class ConsumerStoneOrderRedisStreamConfig extends RedisStreamConfig {
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlOC(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.StoneQueue stream = MQConst.StoneQueue.STONE_ORDER_COUPON;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-stone/src/main/java/com/liquidnet/servce/consumer/stone/service/config/ConsumerStoneUserRedisStreamConfig.java

@@ -28,7 +28,7 @@ public class ConsumerStoneUserRedisStreamConfig extends RedisStreamConfig {
 
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlStoneInsertUser(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.StoneQueue stream = MQConst.StoneQueue.STONE_INSERT_USER;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/config/ConsumerSmileUserRedisStreamConfig.java

@@ -29,7 +29,7 @@ public class ConsumerSmileUserRedisStreamConfig extends RedisStreamConfig {
 
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlSU(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.SmileQueue stream = MQConst.SmileQueue.SMILE_USER;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/config/ConsumerSweetAnswerRedisStreamConfig.java

@@ -29,7 +29,7 @@ public class ConsumerSweetAnswerRedisStreamConfig extends RedisStreamConfig {
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlSAI(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.SweetQueue stream = MQConst.SweetQueue.SWEET_ANSWER_INSERT;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/config/ConsumerSweetAntigenicQuestionRedisStreamConfig.java

@@ -29,7 +29,7 @@ public class ConsumerSweetAntigenicQuestionRedisStreamConfig extends RedisStream
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlSAQ(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.SweetQueue stream = MQConst.SweetQueue.SWEET_ANTIGENIC_QUESTION;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/config/ConsumerSweetCityVoteRedisStreamConfig.java

@@ -29,7 +29,7 @@ public class ConsumerSweetCityVoteRedisStreamConfig extends RedisStreamConfig {
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlSCV(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.SweetQueue stream = MQConst.SweetQueue.SWEET_CITY_VOTE;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/config/ConsumerSweetIntegralActivityDrawRedisStreamConfig.java

@@ -29,7 +29,7 @@ public class ConsumerSweetIntegralActivityDrawRedisStreamConfig extends RedisStr
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlSIAD(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.SweetQueue stream = SWEET_INTEGRAL_ACTIVITY_DRAW;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/config/ConsumerSweetMaoDengConfig.java

@@ -30,7 +30,7 @@ public class ConsumerSweetMaoDengConfig extends RedisStreamConfig {
 
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlSWMTI(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.SweetQueue stream = SWEET_WECHAT_MAODENG_TEXT_INSERT;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/config/ConsumerSweetOtherApiStreamConfig.java

@@ -33,7 +33,7 @@ public class ConsumerSweetOtherApiStreamConfig extends RedisStreamConfig {
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlSTM(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.SweetQueue stream = MQConst.SweetQueue.SWEET_TEMPLATE_MSG;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/config/ConsumerSweetPosterRdsReceiverConfig.java

@@ -30,7 +30,7 @@ public class ConsumerSweetPosterRdsReceiverConfig extends RedisStreamConfig {
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlSP(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.SweetQueue stream = SWEET_POSTER;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/config/ConsumerSweetRemindRedisStreamConfig.java

@@ -29,7 +29,7 @@ public class ConsumerSweetRemindRedisStreamConfig extends RedisStreamConfig {
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlSRI(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.SweetQueue stream = SWEET_REMIND_INSERT;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/config/ConsumerSweetSqlLuckDrawRedisStreamConfig.java

@@ -29,7 +29,7 @@ public class ConsumerSweetSqlLuckDrawRedisStreamConfig extends RedisStreamConfig
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlLR(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.SweetQueue stream = LUCK_DRAW;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/config/ConsumerSweetSqlUserRelationMDSKRedisStreamConfig.java

@@ -29,7 +29,7 @@ public class ConsumerSweetSqlUserRelationMDSKRedisStreamConfig extends RedisStre
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlARM(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.SweetQueue stream = ARTISTS_RELATION_MDSK;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/config/ConsumerSweetSqlUserRelationRedisStreamConfig.java

@@ -30,7 +30,7 @@ public class ConsumerSweetSqlUserRelationRedisStreamConfig extends RedisStreamCo
 
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlAR_RE(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.SweetQueue stream = ARTISTS_RELATION;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-sweet/src/main/java/com/liquidnet/service/consumer/sweet/config/ConsumerSweetUserRedisStreamConfig.java

@@ -29,7 +29,7 @@ public class ConsumerSweetUserRedisStreamConfig extends RedisStreamConfig {
     StringRedisTemplate stringRedisTemplate;
 
     @Bean
-    public List<Subscription> subscriptionSql(RedisConnectionFactory factory) {
+    public List<Subscription> subscriptionSqlSWUI(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.SweetQueue stream = SWEET_WECHAT_USER_INSERT;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());