Merge remote-tracking branch 'origin/consumer_unite' into consumer_unite

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

@@ -31,7 +31,7 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
     StringRedisTemplate stringRedisTemplate;
     @Autowired
     ConsumerCommonSQL0Receiver consumerCommonSQL0Receiver;
-
+    /*------goblin------*/
     @Autowired
     ConsumerGoblinNftOrderReceiver consumerGoblinNftOrderReceiver;
     @Autowired
@@ -42,14 +42,17 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
     ConsumerGoblinSqlCouponReceiver consumerGoblinSqlCouponReceiver;
     @Autowired
     ConsumerGoblinSqlArtworkGenReceiver consumerGoblinSqlArtworkGenReceiver;
+    /*------adam------*/
     @Autowired
     ConsumerAdamSqlURegisterReceiver consumerAdamURegisterRdsReceiver;
     @Autowired
     ConsumerAdamSqlUCenterReceiver consumerAdamUCenterRdsReceiver;
     @Autowired
     ConsumerAdamSqlUMemberReceiver consumerAdamUMemberRdsReceiver;
+    /*------kylin------*/
     @Autowired
     ConsumerKylinSqlStationReceiver consumerKylinSqlStationReceiver;
+    /*------slime------*/
     @Autowired
     ConsumerSlimeSqlFieldReceiver consumerSlimeSqlFieldReceiver;
     @Autowired
@@ -64,23 +67,6 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
     ConsumerSlimeSqlLineReceiver consumerSlimeSqlLineReceiver;
     @Autowired
     ConsumerSlimeSqlPerformanceInsertReceiver consumerSlimeSqlPerformanceInsertReceiver;
-
-//    @Bean
-//    public List<Subscription> subscriptionSQL0(RedisConnectionFactory factory) {
-//        List<Subscription> subscriptionList = new ArrayList<>();
-//        MQConst.CommonQueue stream = MQConst.CommonQueue.SQL0;
-//        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
-//        for (int i = 0; i < 5; i++) {
-//            StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//            subscriptionList.add(listenerContainer.receiveAutoAck(
-//                    Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),
-//                    StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerCommonSQL0Receiver
-//            ));
-//            listenerContainer.start();
-//        }
-//        return subscriptionList;
-//    }
-
     /*------sweet------*/
     @Autowired
     ConsumerSweetAnswerRdsReceiver consumerSweetAnswerRdsReceiver;