迁移 consumer-slowly 部分

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

@@ -32,7 +32,7 @@ public class ConsumerCandyCouponBackRedisStreamConfig extends RedisStreamConfig
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.CandyQueue stream = MQConst.CandyQueue.COUPON_BACK;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
-        for (int i = 0; i < 5; 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)),

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

@@ -32,7 +32,7 @@ public class ConsumerCandyCouponOrderBackRedisStreamConfig extends RedisStreamCo
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.CandyQueue stream = MQConst.CandyQueue.COUPON_ORDER_BACK;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
-        for (int i = 0; i < 5; 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)),

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

@@ -32,7 +32,7 @@ public class ConsumerCandyCouponReceiveRedisStreamConfig extends RedisStreamConf
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.CandyQueue stream = MQConst.CandyQueue.COUPON_RECEIVE;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
-        for (int i = 0; i < 5; 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)),

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

@@ -32,7 +32,7 @@ public class ConsumerCandyCouponUseRedisStreamConfig extends RedisStreamConfig {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.CandyQueue stream = MQConst.CandyQueue.COUPON_USE;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
-        for (int i = 0; i < 5; 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)),

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

@@ -30,7 +30,7 @@ public class ConsumerGoblinOrderAGRedisStreamConfig extends RedisStreamConfig {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_ORDER_AGAIN;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
-        for (int i = 0; i < 5; 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)),

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

@@ -30,7 +30,7 @@ public class ConsumerGoblinOrderCPRedisStreamConfig extends RedisStreamConfig {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_ORDER_CREATE_PAY;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
-        for (int i = 0; i < 5; 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)),

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

+package com.liquidnet.service.consumer.base.config.goblin;
+
+import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.consumer.base.receiver.goblin.ConsumerGoblinOrderCloseRdsReceiver;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.connection.stream.Consumer;
+import org.springframework.data.redis.connection.stream.MapRecord;
+import org.springframework.data.redis.connection.stream.ReadOffset;
+import org.springframework.data.redis.connection.stream.StreamOffset;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.data.redis.stream.StreamMessageListenerContainer;
+import org.springframework.data.redis.stream.Subscription;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Configuration
+public class ConsumerGoblinOrderCRedisStreamConfig extends RedisStreamConfig {
+    @Autowired
+    StringRedisTemplate stringRedisTemplate;
+    @Autowired
+    ConsumerGoblinOrderCloseRdsReceiver consumerGoblinOrderCloseRdsReceiver;
+
+
+    @Bean//
+    public List<Subscription> subscriptionSqlGoblinOrderClose(RedisConnectionFactory factory) {
+        List<Subscription> subscriptionList = new ArrayList<>();
+        MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_ORDER_CLOSE;
+        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
+        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)),
+                    StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerGoblinOrderCloseRdsReceiver
+            ));
+            listenerContainer.start();
+        }
+        return subscriptionList;
+    }
+}

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

+package com.liquidnet.service.consumer.base.config.goblin;
+
+import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.consumer.base.receiver.goblin.ConsumerGoblinSelfMarketRdsReceiver;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.connection.stream.Consumer;
+import org.springframework.data.redis.connection.stream.MapRecord;
+import org.springframework.data.redis.connection.stream.ReadOffset;
+import org.springframework.data.redis.connection.stream.StreamOffset;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.data.redis.stream.StreamMessageListenerContainer;
+import org.springframework.data.redis.stream.Subscription;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Configuration
+public class ConsumerGoblinSelfMarketRedisStreamConfig extends RedisStreamConfig {
+    @Autowired
+    StringRedisTemplate stringRedisTemplate;
+    @Autowired
+    ConsumerGoblinSelfMarketRdsReceiver consumerGoblinSelfMarketRdsReceiver;
+
+
+    @Bean//
+    public List<Subscription> selfMarket(RedisConnectionFactory factory) {
+        List<Subscription> subscriptionList = new ArrayList<>();
+        MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_SELF_MARKET;
+        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
+        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)),
+                    StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerGoblinSelfMarketRdsReceiver
+            ));
+            listenerContainer.start();
+        }
+        return subscriptionList;
+    }
+
+}

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

+package com.liquidnet.service.consumer.base.config.goblin;
+
+import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.consumer.base.receiver.goblin.ConsumerGoblinShopCartReceiver;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.connection.stream.Consumer;
+import org.springframework.data.redis.connection.stream.MapRecord;
+import org.springframework.data.redis.connection.stream.ReadOffset;
+import org.springframework.data.redis.connection.stream.StreamOffset;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.data.redis.stream.StreamMessageListenerContainer;
+import org.springframework.data.redis.stream.Subscription;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Configuration
+public class ConsumerGoblinShopCartStreamConfig extends RedisStreamConfig {
+    @Autowired
+    ConsumerGoblinShopCartReceiver consumerGoblinShopCartReceiver;
+    @Autowired
+    StringRedisTemplate stringRedisTemplate;
+
+    @Bean//
+    public List<Subscription> shopCart(RedisConnectionFactory factory) {
+        List<Subscription> subscriptionList = new ArrayList<>();
+        MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_SHOP_CART;
+        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
+        for (int i = 0; i < 1; 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()), consumerGoblinShopCartReceiver
+            ));
+            listenerContainer.start();
+        }
+        return subscriptionList;
+    }
+
+}

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

+package com.liquidnet.service.consumer.base.config.goblin;
+
+import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.consumer.base.receiver.goblin.ConsumerGoblinStoreMarketRdsReceiver;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.connection.stream.Consumer;
+import org.springframework.data.redis.connection.stream.MapRecord;
+import org.springframework.data.redis.connection.stream.ReadOffset;
+import org.springframework.data.redis.connection.stream.StreamOffset;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.data.redis.stream.StreamMessageListenerContainer;
+import org.springframework.data.redis.stream.Subscription;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Configuration
+public class ConsumerGoblinStoneMarketRedisStreamConfig extends RedisStreamConfig {
+    @Autowired
+    ConsumerGoblinStoreMarketRdsReceiver consumerGoblinStoreMarketRdsReceiver;
+    @Autowired
+    StringRedisTemplate stringRedisTemplate;
+
+    @Bean//
+    public List<Subscription> storeMarket(RedisConnectionFactory factory) {
+        List<Subscription> subscriptionList = new ArrayList<>();
+        MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_STORE_MARKET;
+        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
+        for (int i = 0; i < 1; 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()), consumerGoblinStoreMarketRdsReceiver
+            ));
+            listenerContainer.start();
+        }
+        return subscriptionList;
+    }
+}

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

+package com.liquidnet.service.consumer.base.config.goblin;
+
+import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.consumer.base.receiver.goblin.ConsumerGoblinStoreOrderRdsReceiver;
+import lombok.var;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.connection.stream.Consumer;
+import org.springframework.data.redis.connection.stream.MapRecord;
+import org.springframework.data.redis.connection.stream.ReadOffset;
+import org.springframework.data.redis.connection.stream.StreamOffset;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.data.redis.stream.StreamMessageListenerContainer;
+import org.springframework.data.redis.stream.Subscription;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Configuration
+public class ConsumerGoblinStoreOrderRedisStreamConfig extends RedisStreamConfig {
+    @Autowired
+    ConsumerGoblinStoreOrderRdsReceiver consumerGoblinStoreOrderRdsReceiver;
+    @Autowired
+    StringRedisTemplate stringRedisTemplate;
+
+    @Bean//
+    public List<Subscription> storeOrder(RedisConnectionFactory factory) {
+        List<Subscription> subscriptionList = new ArrayList<>();
+        MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_STORE_ORDER_OPERA;
+        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
+        for (int i = 0; i < 1; 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()), consumerGoblinStoreOrderRdsReceiver
+            ));
+            listenerContainer.start();
+        }
+        return subscriptionList;
+    }
+
+}

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

+package com.liquidnet.service.consumer.base.config.goblin;
+
+import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.consumer.base.receiver.goblin.ConsumerGoblinUserOrderRdsReceiver;
+import lombok.var;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.connection.stream.Consumer;
+import org.springframework.data.redis.connection.stream.MapRecord;
+import org.springframework.data.redis.connection.stream.ReadOffset;
+import org.springframework.data.redis.connection.stream.StreamOffset;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.data.redis.stream.StreamMessageListenerContainer;
+import org.springframework.data.redis.stream.Subscription;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Configuration
+public class ConsumerGoblinUserOrderRedisStreamConfig extends RedisStreamConfig {
+    @Autowired
+    ConsumerGoblinUserOrderRdsReceiver consumerGoblinUserOrderRdsReceiver;
+    @Autowired
+    StringRedisTemplate stringRedisTemplate;
+
+
+    @Bean//
+    public List<Subscription> userOrder(RedisConnectionFactory factory) {
+        List<Subscription> subscriptionList = new ArrayList<>();
+        MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_USER_ORDER_OPERA;
+        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
+        for (int i = 0; i < 1; 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()), consumerGoblinUserOrderRdsReceiver
+            ));
+            listenerContainer.start();
+        }
+        return subscriptionList;
+    }
+}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/config/ConsumerGoblinXlsRedisStreamConfig.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/config/goblin/ConsumerGoblinXlsRedisStreamConfig.java

-package com.liquidnet.service.consumer.base.config;
+package com.liquidnet.service.consumer.base.config.goblin;
 
 import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
 import com.liquidnet.service.base.constant.MQConst;
-import com.liquidnet.service.consumer.base.receiver.ConsumerGoblinXlsRdsReceiver;
-import lombok.var;
+import com.liquidnet.service.consumer.base.receiver.goblin.ConsumerGoblinXlsRdsReceiver;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -32,7 +31,7 @@ public class ConsumerGoblinXlsRedisStreamConfig extends RedisStreamConfig {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_XLS_OPERA;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
-        for (int i = 0; i < 1; i++) {
+        for (int i = 0; i < 2; i++) {
             StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer = this.buildStreamMessageListenerContainer(factory);
             subscriptionList.add(listenerContainer.receiveAutoAck(
                     Consumer.from(stream.getGroup(), getConsumerName(stream.name() + i)),

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

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

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

@@ -32,7 +32,7 @@ public class ConsumerKylinSqlOrderRefundRedisStreamConfig extends RedisStreamCon
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.KylinQueue stream = MQConst.KylinQueue.SQL_ORDER_REFUND;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
-        for (int i = 0; i < 3; i++) {
+        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)),

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

+package com.liquidnet.service.consumer.base.config.kylin;
+
+import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.consumer.base.receiver.kylin.ConsumerKylinSqlOrderWithdrawRdsReceiver;
+import lombok.var;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.connection.stream.Consumer;
+import org.springframework.data.redis.connection.stream.MapRecord;
+import org.springframework.data.redis.connection.stream.ReadOffset;
+import org.springframework.data.redis.connection.stream.StreamOffset;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.data.redis.stream.StreamMessageListenerContainer;
+import org.springframework.data.redis.stream.Subscription;
+
+import java.util.ArrayList;
+import java.util.List;
+
+@Configuration
+public class ConsumerKylinSqlOrderWithdrawRedisStreamConfig extends RedisStreamConfig {
+    @Autowired
+    ConsumerKylinSqlOrderWithdrawRdsReceiver consumerKylinSqlOrderWithdrawRdsReceiver;
+    @Autowired
+    StringRedisTemplate stringRedisTemplate;
+
+    @Bean//
+    public List<Subscription> orderWithDraw(RedisConnectionFactory factory) {
+        List<Subscription> subscriptionList = new ArrayList<>();
+        MQConst.KylinQueue stream = MQConst.KylinQueue.SQL_ORDER_WITHDRAW;
+        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
+        for (int i = 0; i < 1; 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()), consumerKylinSqlOrderWithdrawRdsReceiver
+            ));
+            listenerContainer.start();
+        }
+        return subscriptionList;
+    }
+}

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

+package com.liquidnet.service.consumer.base.config.kylin;
+
+import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.consumer.base.receiver.kylin.ConsumerKylinSqlPerformanceLackRdsReceiver;
+import lombok.var;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.connection.stream.Consumer;
+import org.springframework.data.redis.connection.stream.MapRecord;
+import org.springframework.data.redis.connection.stream.ReadOffset;
+import org.springframework.data.redis.connection.stream.StreamOffset;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.data.redis.stream.StreamMessageListenerContainer;
+import org.springframework.data.redis.stream.Subscription;
+
+import java.util.ArrayList;
+import java.util.List;
+
+
+@Configuration
+public class ConsumerKylinSqlPerformanceLackRedisStreamConfig extends RedisStreamConfig {
+    @Autowired
+    ConsumerKylinSqlPerformanceLackRdsReceiver consumerKylinSqlPerformanceLackRdsReceiver;
+    @Autowired
+    StringRedisTemplate stringRedisTemplate;
+
+    @Bean//
+    public List<Subscription> lack(RedisConnectionFactory factory) {
+        List<Subscription> subscriptionList = new ArrayList<>();
+        MQConst.KylinQueue stream = MQConst.KylinQueue.SQL_PERFORMANCE_LACK;
+        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
+        for (int i = 0; i < 1; 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()), consumerKylinSqlPerformanceLackRdsReceiver
+            ));
+            listenerContainer.start();
+        }
+        return subscriptionList;
+    }
+
+}

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

+package com.liquidnet.service.consumer.base.config.kylin;
+
+import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.consumer.base.receiver.kylin.ConsumerKylinTransferRdsReceiver;
+import lombok.var;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.connection.stream.Consumer;
+import org.springframework.data.redis.connection.stream.MapRecord;
+import org.springframework.data.redis.connection.stream.ReadOffset;
+import org.springframework.data.redis.connection.stream.StreamOffset;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.data.redis.stream.StreamMessageListenerContainer;
+import org.springframework.data.redis.stream.Subscription;
+
+import java.util.ArrayList;
+import java.util.List;
+
+
+@Configuration
+public class ConsumerKylinSqlTransferRedisStreamConfig extends RedisStreamConfig {
+    @Autowired
+    ConsumerKylinTransferRdsReceiver consumerKylinTransferRdsReceiver;
+    @Autowired
+    StringRedisTemplate stringRedisTemplate;
+
+
+    @Bean//
+    public List<Subscription> transfer(RedisConnectionFactory factory) {
+        List<Subscription> subscriptionList = new ArrayList<>();
+        MQConst.KylinQueue stream = MQConst.KylinQueue.SQL_TRANSFER;
+        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
+        for (int i = 0; i < 1; 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()), consumerKylinTransferRdsReceiver
+            ));
+            listenerContainer.start();
+        }
+        return subscriptionList;
+    }
+}

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

+package com.liquidnet.service.consumer.base.config.kylin;
+
+import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.consumer.base.receiver.kylin.ConsumerKylinTransferResultRdsReceiver;
+import lombok.var;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.connection.RedisConnectionFactory;
+import org.springframework.data.redis.connection.stream.Consumer;
+import org.springframework.data.redis.connection.stream.MapRecord;
+import org.springframework.data.redis.connection.stream.ReadOffset;
+import org.springframework.data.redis.connection.stream.StreamOffset;
+import org.springframework.data.redis.core.StringRedisTemplate;
+import org.springframework.data.redis.stream.StreamMessageListenerContainer;
+import org.springframework.data.redis.stream.Subscription;
+
+import java.util.ArrayList;
+import java.util.List;
+
+
+@Configuration
+public class ConsumerKylinSqlTransferResultRedisStreamConfig extends RedisStreamConfig {
+    @Autowired
+    ConsumerKylinTransferResultRdsReceiver consumerKylinTransferResultRdsReceiver;
+    @Autowired
+    StringRedisTemplate stringRedisTemplate;
+
+    @Bean//
+    public List<Subscription> transferResult(RedisConnectionFactory factory) {
+        List<Subscription> subscriptionList = new ArrayList<>();
+        MQConst.KylinQueue stream = MQConst.KylinQueue.SQL_TRANSFER_RESULT;
+        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
+        for (int i = 0; i < 1; 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()), consumerKylinTransferResultRdsReceiver
+            ));
+            listenerContainer.start();
+        }
+        return subscriptionList;
+    }
+}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/config/ConsumerTransferRedisStreamConfig.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/config/kylin/ConsumerTransferRedisStreamConfig.java

-package com.liquidnet.service.consumer.base.config;
+package com.liquidnet.service.consumer.base.config.kylin;
 
 import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
 import com.liquidnet.service.base.constant.MQConst;
-import com.liquidnet.service.consumer.base.receiver.ConsumerKylinTransferOverTimeRdsReceiver;
+import com.liquidnet.service.consumer.base.receiver.kylin.ConsumerKylinTransferOverTimeRdsReceiver;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -36,7 +36,7 @@ public class ConsumerTransferRedisStreamConfig extends RedisStreamConfig {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.KylinQueue stream = MQConst.KylinQueue.SQL_TRANSFER_OVERTIME;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
-        for (int i = 0; i < 1; i++) {
+        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)),

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

@@ -32,7 +32,7 @@ public class ConsumerStoneLogsRedisStreamConfig extends RedisStreamConfig {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.StoneQueue stream = MQConst.StoneQueue.STONE_INSERT_LOGS;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
-        for (int i = 0; i < 5; 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)),

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

@@ -32,7 +32,7 @@ public class ConsumerStoneOrderRedisStreamConfig extends RedisStreamConfig {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.StoneQueue stream = MQConst.StoneQueue.STONE_ORDER_COUPON;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
-        for (int i = 0; i < 5; 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)),

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

@@ -31,7 +31,7 @@ public class ConsumerStoneUserRedisStreamConfig extends RedisStreamConfig {
         List<Subscription> subscriptionList = new ArrayList<>();
         MQConst.StoneQueue stream = MQConst.StoneQueue.STONE_INSERT_USER;
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
-        for (int i = 0; i < 5; 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)),

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/goblin/ConsumerGoblinOrderCloseRdsReceiver.java

+package com.liquidnet.service.consumer.base.receiver.goblin;
+
+import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.consumer.base.receiver.AbstractSqlRedisReceiver;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ConsumerGoblinOrderCloseRdsReceiver extends AbstractSqlRedisReceiver {
+    @Override
+    protected String getRedisStreamKey() {
+        return MQConst.GoblinQueue.GOBLIN_ORDER_CLOSE.getKey();
+    }
+
+    @Override
+    protected String getRedisStreamGroup() {
+        return MQConst.GoblinQueue.GOBLIN_ORDER_CLOSE.getGroup();
+    }
+}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/goblin/ConsumerGoblinSelfMarketRdsReceiver.java

+package com.liquidnet.service.consumer.base.receiver.goblin;
+
+import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.consumer.base.receiver.AbstractSqlRedisReceiver;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ConsumerGoblinSelfMarketRdsReceiver extends AbstractSqlRedisReceiver {
+    @Override
+    protected String getRedisStreamKey() {
+        return MQConst.GoblinQueue.GOBLIN_SELF_MARKET.getKey();
+    }
+
+    @Override
+    protected String getRedisStreamGroup() {
+        return MQConst.GoblinQueue.GOBLIN_SELF_MARKET.getGroup();
+    }
+}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/goblin/ConsumerGoblinShopCartReceiver.java

+package com.liquidnet.service.consumer.base.receiver.goblin;
+
+import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.consumer.base.receiver.AbstractSqlRedisReceiver;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ConsumerGoblinShopCartReceiver extends AbstractSqlRedisReceiver {
+    @Override
+    protected String getRedisStreamKey() {
+        return MQConst.GoblinQueue.GOBLIN_SHOP_CART.getKey();
+    }
+
+    @Override
+    protected String getRedisStreamGroup() {
+        return MQConst.GoblinQueue.GOBLIN_SHOP_CART.getGroup();
+    }
+}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/goblin/ConsumerGoblinStoreMarketRdsReceiver.java

+package com.liquidnet.service.consumer.base.receiver.goblin;
+
+import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.consumer.base.receiver.AbstractSqlRedisReceiver;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ConsumerGoblinStoreMarketRdsReceiver extends AbstractSqlRedisReceiver {
+    @Override
+    protected String getRedisStreamKey() {
+        return MQConst.GoblinQueue.GOBLIN_STORE_MARKET.getKey();
+    }
+
+    @Override
+    protected String getRedisStreamGroup() {
+        return MQConst.GoblinQueue.GOBLIN_STORE_MARKET.getGroup();
+    }
+}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/goblin/ConsumerGoblinStoreOrderRdsReceiver.java

+package com.liquidnet.service.consumer.base.receiver.goblin;
+
+import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.consumer.base.receiver.AbstractSqlRedisReceiver;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ConsumerGoblinStoreOrderRdsReceiver extends AbstractSqlRedisReceiver {
+    @Override
+    protected String getRedisStreamKey() {
+        return MQConst.GoblinQueue.GOBLIN_STORE_ORDER_OPERA.getKey();
+    }
+
+    @Override
+    protected String getRedisStreamGroup() {
+        return MQConst.GoblinQueue.GOBLIN_STORE_ORDER_OPERA.getGroup();
+    }
+}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/goblin/ConsumerGoblinUserOrderRdsReceiver.java

+package com.liquidnet.service.consumer.base.receiver.goblin;
+
+import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.consumer.base.receiver.AbstractSqlRedisReceiver;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ConsumerGoblinUserOrderRdsReceiver extends AbstractSqlRedisReceiver {
+    @Override
+    protected String getRedisStreamKey() {
+        return MQConst.GoblinQueue.GOBLIN_USER_ORDER_OPERA.getKey();
+    }
+
+    @Override
+    protected String getRedisStreamGroup() {
+        return MQConst.GoblinQueue.GOBLIN_USER_ORDER_OPERA.getGroup();
+    }
+}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/ConsumerGoblinXlsRdsReceiver.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/goblin/ConsumerGoblinXlsRdsReceiver.java

-package com.liquidnet.service.consumer.base.receiver;
+package com.liquidnet.service.consumer.base.receiver.goblin;
 
 import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.consumer.base.receiver.AbstractXlsRedisReceiver;
 import org.springframework.stereotype.Component;
 
 @Component

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/kylin/ConsumerKylinSqlOrderWithdrawRdsReceiver.java

+package com.liquidnet.service.consumer.base.receiver.kylin;
+
+import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.consumer.base.receiver.AbstractSqlRedisReceiver;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ConsumerKylinSqlOrderWithdrawRdsReceiver extends AbstractSqlRedisReceiver {
+    @Override
+    protected String getRedisStreamKey() {
+        return MQConst.KylinQueue.SQL_ORDER_WITHDRAW.getKey();
+    }
+
+    @Override
+    protected String getRedisStreamGroup() {
+        return MQConst.KylinQueue.SQL_ORDER_WITHDRAW.getGroup();
+    }
+}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/kylin/ConsumerKylinSqlPerformanceLackRdsReceiver.java

+package com.liquidnet.service.consumer.base.receiver.kylin;
+
+import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.consumer.base.receiver.AbstractSqlRedisReceiver;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ConsumerKylinSqlPerformanceLackRdsReceiver extends AbstractSqlRedisReceiver {
+    @Override
+    protected String getRedisStreamKey() {
+        return MQConst.KylinQueue.SQL_PERFORMANCE_LACK.getKey();
+    }
+
+    @Override
+    protected String getRedisStreamGroup() {
+        return MQConst.KylinQueue.SQL_PERFORMANCE_LACK.getGroup();
+    }
+}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/ConsumerKylinTransferOverTimeRdsReceiver.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/kylin/ConsumerKylinTransferOverTimeRdsReceiver.java

-package com.liquidnet.service.consumer.base.receiver;
+package com.liquidnet.service.consumer.base.receiver.kylin;
 
 import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.consumer.base.receiver.AbstractOptOrderTransferOverTimeRedisReceiver;
 import org.springframework.stereotype.Component;
 
 @Component

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/kylin/ConsumerKylinTransferRdsReceiver.java

+package com.liquidnet.service.consumer.base.receiver.kylin;
+
+import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.consumer.base.receiver.AbstractSqlRedisReceiver;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ConsumerKylinTransferRdsReceiver extends AbstractSqlRedisReceiver {
+    @Override
+    protected String getRedisStreamKey() {
+        return MQConst.KylinQueue.SQL_TRANSFER.getKey();
+    }
+
+    @Override
+    protected String getRedisStreamGroup() {
+        return MQConst.KylinQueue.SQL_TRANSFER.getGroup();
+    }
+}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/kylin/ConsumerKylinTransferResultRdsReceiver.java

+package com.liquidnet.service.consumer.base.receiver.kylin;
+
+import com.liquidnet.service.base.constant.MQConst;
+import com.liquidnet.service.consumer.base.receiver.AbstractSqlRedisReceiver;
+import org.springframework.stereotype.Component;
+
+@Component
+public class ConsumerKylinTransferResultRdsReceiver extends AbstractSqlRedisReceiver {
+    @Override
+    protected String getRedisStreamKey() {
+        return MQConst.KylinQueue.SQL_TRANSFER_RESULT.getKey();
+    }
+
+    @Override
+    protected String getRedisStreamGroup() {
+        return MQConst.KylinQueue.SQL_TRANSFER_RESULT.getGroup();
+    }
+}

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

-package com.liquidnet.service.consumer.slowly.config;
-
-import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
-import com.liquidnet.service.base.constant.MQConst;
-import com.liquidnet.service.consumer.slowly.receiver.ConsumerGoblinOrderCloseRdsReceiver;
-import lombok.var;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.data.redis.connection.RedisConnectionFactory;
-import org.springframework.data.redis.connection.stream.Consumer;
-import org.springframework.data.redis.connection.stream.MapRecord;
-import org.springframework.data.redis.connection.stream.ReadOffset;
-import org.springframework.data.redis.connection.stream.StreamOffset;
-import org.springframework.data.redis.core.StringRedisTemplate;
-import org.springframework.data.redis.stream.StreamMessageListenerContainer;
-import org.springframework.data.redis.stream.Subscription;
-
-import java.util.ArrayList;
-import java.util.List;
-
-@Configuration
-public class ConsumerGoblinOrderCRedisStreamConfig extends RedisStreamConfig {
-    @Autowired
-    StringRedisTemplate stringRedisTemplate;
-    @Autowired
-    ConsumerGoblinOrderCloseRdsReceiver consumerGoblinOrderCloseRdsReceiver;
-
-//    /**
-//     * 缺票登记
-//     *
-//     * @param listenerContainer
-//     * @param t
-//     * @return
-//     */
-//    private Subscription receiveGoblinOrderCOrder(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
-//        return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_ORDER_CLOSE.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_ORDER_CLOSE.name() + t)),
-//                StreamOffset.create(MQConst.GoblinQueue.GOBLIN_ORDER_CLOSE.getKey(), ReadOffset.lastConsumed()), consumerGoblinOrderCloseRdsReceiver);
-//    }
+//package com.liquidnet.service.consumer.slowly.config;
 //
-//    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
+//import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+//import com.liquidnet.service.base.constant.MQConst;
+//import com.liquidnet.service.consumer.slowly.receiver.ConsumerGoblinOrderCloseRdsReceiver;
+//import lombok.var;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.context.annotation.Configuration;
+//import org.springframework.data.redis.connection.RedisConnectionFactory;
+//import org.springframework.data.redis.connection.stream.Consumer;
+//import org.springframework.data.redis.connection.stream.MapRecord;
+//import org.springframework.data.redis.connection.stream.ReadOffset;
+//import org.springframework.data.redis.connection.stream.StreamOffset;
+//import org.springframework.data.redis.core.StringRedisTemplate;
+//import org.springframework.data.redis.stream.StreamMessageListenerContainer;
+//import org.springframework.data.redis.stream.Subscription;
 //
-//    /* -------------------------------------------------------- ｜ 缺票登记 */
+//import java.util.ArrayList;
+//import java.util.List;
 //
-//    @Bean
-//    public Subscription subscriptionGoblinOrderC0(RedisConnectionFactory factory) {
-//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveGoblinOrderCOrder(listenerContainer, 0);
-//        listenerContainer.start();
-//        return subscription;
-//    }
-
-//    @Bean
-//    public Subscription subscriptionGoblinOrderC1(RedisConnectionFactory factory) {
-//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveGoblinOrderCOrder(listenerContainer, 1);
-//        listenerContainer.start();
-//        return subscription;
-//    }
+//@Configuration
+//public class ConsumerGoblinOrderCRedisStreamConfig extends RedisStreamConfig {
+//    @Autowired
+//    StringRedisTemplate stringRedisTemplate;
+//    @Autowired
+//    ConsumerGoblinOrderCloseRdsReceiver consumerGoblinOrderCloseRdsReceiver;
+//
+////    /**
+////     * 缺票登记
+////     *
+////     * @param listenerContainer
+////     * @param t
+////     * @return
+////     */
+////    private Subscription receiveGoblinOrderCOrder(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
+////        return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_ORDER_CLOSE.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_ORDER_CLOSE.name() + t)),
+////                StreamOffset.create(MQConst.GoblinQueue.GOBLIN_ORDER_CLOSE.getKey(), ReadOffset.lastConsumed()), consumerGoblinOrderCloseRdsReceiver);
+////    }
+////
+////    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
+////
+////    /* -------------------------------------------------------- ｜ 缺票登记 */
+////
+////    @Bean
+////    public Subscription subscriptionGoblinOrderC0(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveGoblinOrderCOrder(listenerContainer, 0);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+//
+////    @Bean
+////    public Subscription subscriptionGoblinOrderC1(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveGoblinOrderCOrder(listenerContainer, 1);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+////
+////    @Bean
+////    public Subscription subscriptionGoblinOrderC2(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveGoblinOrderCOrder(listenerContainer, 2);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+//
+//    /* -------------------------------------------------------- ｜  */
 //
-//    @Bean
-//    public Subscription subscriptionGoblinOrderC2(RedisConnectionFactory factory) {
-//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveGoblinOrderCOrder(listenerContainer, 2);
-//        listenerContainer.start();
-//        return subscription;
+//    @Bean//
+//    public List<Subscription> subscriptionSqlGoblinOrderClose(RedisConnectionFactory factory) {
+//        List<Subscription> subscriptionList = new ArrayList<>();
+//        MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_ORDER_CLOSE;
+//        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()), consumerGoblinOrderCloseRdsReceiver
+//            ));
+//            listenerContainer.start();
+//        }
+//        return subscriptionList;
 //    }
-
-    /* -------------------------------------------------------- ｜  */
-
-    @Bean//
-    public List<Subscription> subscriptionSqlGoblinOrderClose(RedisConnectionFactory factory) {
-        List<Subscription> subscriptionList = new ArrayList<>();
-        MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_ORDER_CLOSE;
-        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()), consumerGoblinOrderCloseRdsReceiver
-            ));
-            listenerContainer.start();
-        }
-        return subscriptionList;
-    }
-}
+//}

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

-package com.liquidnet.service.consumer.slowly.config;
-
-import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
-import com.liquidnet.service.base.constant.MQConst;
-import com.liquidnet.service.consumer.slowly.receiver.ConsumerGoblinSelfMarketRdsReceiver;
-import lombok.var;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.data.redis.connection.RedisConnectionFactory;
-import org.springframework.data.redis.connection.stream.Consumer;
-import org.springframework.data.redis.connection.stream.MapRecord;
-import org.springframework.data.redis.connection.stream.ReadOffset;
-import org.springframework.data.redis.connection.stream.StreamOffset;
-import org.springframework.data.redis.stream.StreamMessageListenerContainer;
-import org.springframework.data.redis.stream.Subscription;
-
-@Configuration
-public class ConsumerGoblinSelfMarketRedisStreamConfig extends RedisStreamConfig {
-    @Autowired
-    ConsumerGoblinSelfMarketRdsReceiver consumerGoblinSelfMarketRdsReceiver;
-
-    /**
-     * 缺票登记
-     *
-     * @param listenerContainer
-     * @param t
-     * @return
-     */
-    private Subscription receiveGoblinSelfMarket(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
-        return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_SELF_MARKET.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_SELF_MARKET.name() + t)),
-                StreamOffset.create(MQConst.GoblinQueue.GOBLIN_SELF_MARKET.getKey(), ReadOffset.lastConsumed()), consumerGoblinSelfMarketRdsReceiver);
-    }
-
-    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
-
-    /* -------------------------------------------------------- ｜ 缺票登记 */
-
-    @Bean
-    public Subscription subscriptionGoblinSelfMarket0(RedisConnectionFactory factory) {
-        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveGoblinSelfMarket(listenerContainer, 0);
-        listenerContainer.start();
-        return subscription;
-    }
-
-//    @Bean
-//    public Subscription subscriptionGoblinSelfMarket1(RedisConnectionFactory factory) {
-//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveGoblinSelfMarket(listenerContainer, 1);
-//        listenerContainer.start();
-//        return subscription;
+//package com.liquidnet.service.consumer.slowly.config;
+//
+//import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+//import com.liquidnet.service.base.constant.MQConst;
+//import com.liquidnet.service.consumer.slowly.receiver.ConsumerGoblinSelfMarketRdsReceiver;
+//import lombok.var;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.context.annotation.Configuration;
+//import org.springframework.data.redis.connection.RedisConnectionFactory;
+//import org.springframework.data.redis.connection.stream.Consumer;
+//import org.springframework.data.redis.connection.stream.MapRecord;
+//import org.springframework.data.redis.connection.stream.ReadOffset;
+//import org.springframework.data.redis.connection.stream.StreamOffset;
+//import org.springframework.data.redis.stream.StreamMessageListenerContainer;
+//import org.springframework.data.redis.stream.Subscription;
+//
+//@Configuration
+//public class ConsumerGoblinSelfMarketRedisStreamConfig extends RedisStreamConfig {
+//    @Autowired
+//    ConsumerGoblinSelfMarketRdsReceiver consumerGoblinSelfMarketRdsReceiver;
+//
+//    /**
+//     * 缺票登记
+//     *
+//     * @param listenerContainer
+//     * @param t
+//     * @return
+//     */
+//    private Subscription receiveGoblinSelfMarket(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
+//        return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_SELF_MARKET.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_SELF_MARKET.name() + t)),
+//                StreamOffset.create(MQConst.GoblinQueue.GOBLIN_SELF_MARKET.getKey(), ReadOffset.lastConsumed()), consumerGoblinSelfMarketRdsReceiver);
 //    }
 //
+//    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
+//
+//    /* -------------------------------------------------------- ｜ 缺票登记 */
+//
 //    @Bean
-//    public Subscription subscriptionGoblinSelfMarket2(RedisConnectionFactory factory) {
+//    public Subscription subscriptionGoblinSelfMarket0(RedisConnectionFactory factory) {
 //        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveGoblinSelfMarket(listenerContainer, 2);
+//        var subscription = receiveGoblinSelfMarket(listenerContainer, 0);
 //        listenerContainer.start();
 //        return subscription;
 //    }
-
-    /* -------------------------------------------------------- ｜  */
-}
+//
+////    @Bean
+////    public Subscription subscriptionGoblinSelfMarket1(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveGoblinSelfMarket(listenerContainer, 1);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+////
+////    @Bean
+////    public Subscription subscriptionGoblinSelfMarket2(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveGoblinSelfMarket(listenerContainer, 2);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+//
+//    /* -------------------------------------------------------- ｜  */
+//}

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

-package com.liquidnet.service.consumer.slowly.config;
-
-import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
-import com.liquidnet.service.base.constant.MQConst;
-import com.liquidnet.service.consumer.slowly.receiver.ConsumerGoblinShopCartReceiver;
-import lombok.var;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.data.redis.connection.RedisConnectionFactory;
-import org.springframework.data.redis.connection.stream.Consumer;
-import org.springframework.data.redis.connection.stream.MapRecord;
-import org.springframework.data.redis.connection.stream.ReadOffset;
-import org.springframework.data.redis.connection.stream.StreamOffset;
-import org.springframework.data.redis.stream.StreamMessageListenerContainer;
-import org.springframework.data.redis.stream.Subscription;
-
-@Configuration
-public class ConsumerGoblinShopCartStreamConfig extends RedisStreamConfig {
-    @Autowired
-    ConsumerGoblinShopCartReceiver consumerGoblinShopCartReceiver;
-
-    /**
-     * 购物车
-     * @return Subscription
-     */
-    private Subscription receiveSqlShopCart(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
-        return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_SHOP_CART.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_SHOP_CART.name() + t)),
-                StreamOffset.create(MQConst.GoblinQueue.GOBLIN_SHOP_CART.getKey(), ReadOffset.lastConsumed()), consumerGoblinShopCartReceiver);
-    }
-
-    /* -------------------------------------------------------- ｜  */
-
-    @Bean
-    public Subscription subscriptionSqlShopCart0(RedisConnectionFactory factory) {
-        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveSqlShopCart(listenerContainer, 0);
-        listenerContainer.start();
-        return subscription;
-    }
-
-//    @Bean
-//    public Subscription subscriptionSqlShopCart1(RedisConnectionFactory factory) {
-//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveSqlShopCart(listenerContainer, 1);
-//        listenerContainer.start();
-//        return subscription;
-//    }
+//package com.liquidnet.service.consumer.slowly.config;
 //
-//    @Bean
-//    public Subscription subscriptionSqlShopCart2(RedisConnectionFactory factory) {
-//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveSqlShopCart(listenerContainer, 2);
-//        listenerContainer.start();
-//        return subscription;
-//    }
+//import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+//import com.liquidnet.service.base.constant.MQConst;
+//import com.liquidnet.service.consumer.slowly.receiver.ConsumerGoblinShopCartReceiver;
+//import lombok.var;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.context.annotation.Configuration;
+//import org.springframework.data.redis.connection.RedisConnectionFactory;
+//import org.springframework.data.redis.connection.stream.Consumer;
+//import org.springframework.data.redis.connection.stream.MapRecord;
+//import org.springframework.data.redis.connection.stream.ReadOffset;
+//import org.springframework.data.redis.connection.stream.StreamOffset;
+//import org.springframework.data.redis.stream.StreamMessageListenerContainer;
+//import org.springframework.data.redis.stream.Subscription;
 //
-//    @Bean
-//    public Subscription subscriptionSqlShopCart3(RedisConnectionFactory factory) {
-//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveSqlShopCart(listenerContainer, 3);
-//        listenerContainer.start();
-//        return subscription;
+//@Configuration
+//public class ConsumerGoblinShopCartStreamConfig extends RedisStreamConfig {
+//    @Autowired
+//    ConsumerGoblinShopCartReceiver consumerGoblinShopCartReceiver;
+//
+//    /**
+//     * 购物车
+//     * @return Subscription
+//     */
+//    private Subscription receiveSqlShopCart(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
+//        return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_SHOP_CART.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_SHOP_CART.name() + t)),
+//                StreamOffset.create(MQConst.GoblinQueue.GOBLIN_SHOP_CART.getKey(), ReadOffset.lastConsumed()), consumerGoblinShopCartReceiver);
 //    }
 //
+//    /* -------------------------------------------------------- ｜  */
+//
 //    @Bean
-//    public Subscription subscriptionSqlShopCart4(RedisConnectionFactory factory) {
+//    public Subscription subscriptionSqlShopCart0(RedisConnectionFactory factory) {
 //        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveSqlShopCart(listenerContainer, 4);
+//        var subscription = receiveSqlShopCart(listenerContainer, 0);
 //        listenerContainer.start();
 //        return subscription;
 //    }
-
-    /* -------------------------------------------------------- ｜  */
-
-}
+//
+////    @Bean
+////    public Subscription subscriptionSqlShopCart1(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveSqlShopCart(listenerContainer, 1);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+////
+////    @Bean
+////    public Subscription subscriptionSqlShopCart2(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveSqlShopCart(listenerContainer, 2);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+////
+////    @Bean
+////    public Subscription subscriptionSqlShopCart3(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveSqlShopCart(listenerContainer, 3);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+////
+////    @Bean
+////    public Subscription subscriptionSqlShopCart4(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveSqlShopCart(listenerContainer, 4);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+//
+//    /* -------------------------------------------------------- ｜  */
+//
+//}

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

-package com.liquidnet.service.consumer.slowly.config;
-
-import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
-import com.liquidnet.service.base.constant.MQConst;
-import com.liquidnet.service.consumer.slowly.receiver.ConsumerGoblinStoreMarketRdsReceiver;
-import lombok.var;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.data.redis.connection.RedisConnectionFactory;
-import org.springframework.data.redis.connection.stream.Consumer;
-import org.springframework.data.redis.connection.stream.MapRecord;
-import org.springframework.data.redis.connection.stream.ReadOffset;
-import org.springframework.data.redis.connection.stream.StreamOffset;
-import org.springframework.data.redis.stream.StreamMessageListenerContainer;
-import org.springframework.data.redis.stream.Subscription;
-
-@Configuration
-public class ConsumerGoblinStoneMarketRedisStreamConfig extends RedisStreamConfig {
-    @Autowired
-    ConsumerGoblinStoreMarketRdsReceiver consumerGoblinStoreMarketRdsReceiver;
-
-    /**
-     * 缺票登记
-     *
-     * @param listenerContainer
-     * @param t
-     * @return
-     */
-    private Subscription receiveGoblinStoreMarket(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
-        return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_STORE_MARKET.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_STORE_MARKET.name() + t)),
-                StreamOffset.create(MQConst.GoblinQueue.GOBLIN_STORE_MARKET.getKey(), ReadOffset.lastConsumed()), consumerGoblinStoreMarketRdsReceiver);
-    }
-
-    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
-
-    /* -------------------------------------------------------- ｜ 缺票登记 */
-
-    @Bean
-    public Subscription subscriptionGoblinStoreMarket0(RedisConnectionFactory factory) {
-        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveGoblinStoreMarket(listenerContainer, 0);
-        listenerContainer.start();
-        return subscription;
-    }
-
-//    @Bean
-//    public Subscription subscriptionGoblinStoreMarket1(RedisConnectionFactory factory) {
-//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveGoblinStoreMarket(listenerContainer, 1);
-//        listenerContainer.start();
-//        return subscription;
+//package com.liquidnet.service.consumer.slowly.config;
+//
+//import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+//import com.liquidnet.service.base.constant.MQConst;
+//import com.liquidnet.service.consumer.slowly.receiver.ConsumerGoblinStoreMarketRdsReceiver;
+//import lombok.var;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.context.annotation.Configuration;
+//import org.springframework.data.redis.connection.RedisConnectionFactory;
+//import org.springframework.data.redis.connection.stream.Consumer;
+//import org.springframework.data.redis.connection.stream.MapRecord;
+//import org.springframework.data.redis.connection.stream.ReadOffset;
+//import org.springframework.data.redis.connection.stream.StreamOffset;
+//import org.springframework.data.redis.stream.StreamMessageListenerContainer;
+//import org.springframework.data.redis.stream.Subscription;
+//
+//@Configuration
+//public class ConsumerGoblinStoneMarketRedisStreamConfig extends RedisStreamConfig {
+//    @Autowired
+//    ConsumerGoblinStoreMarketRdsReceiver consumerGoblinStoreMarketRdsReceiver;
+//
+//    /**
+//     * 缺票登记
+//     *
+//     * @param listenerContainer
+//     * @param t
+//     * @return
+//     */
+//    private Subscription receiveGoblinStoreMarket(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
+//        return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_STORE_MARKET.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_STORE_MARKET.name() + t)),
+//                StreamOffset.create(MQConst.GoblinQueue.GOBLIN_STORE_MARKET.getKey(), ReadOffset.lastConsumed()), consumerGoblinStoreMarketRdsReceiver);
 //    }
 //
+//    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
+//
+//    /* -------------------------------------------------------- ｜ 缺票登记 */
+//
 //    @Bean
-//    public Subscription subscriptionGoblinStoreMarket2(RedisConnectionFactory factory) {
+//    public Subscription subscriptionGoblinStoreMarket0(RedisConnectionFactory factory) {
 //        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveGoblinStoreMarket(listenerContainer, 2);
+//        var subscription = receiveGoblinStoreMarket(listenerContainer, 0);
 //        listenerContainer.start();
 //        return subscription;
 //    }
-
-    /* -------------------------------------------------------- ｜  */
-}
+//
+////    @Bean
+////    public Subscription subscriptionGoblinStoreMarket1(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveGoblinStoreMarket(listenerContainer, 1);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+////
+////    @Bean
+////    public Subscription subscriptionGoblinStoreMarket2(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveGoblinStoreMarket(listenerContainer, 2);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+//
+//    /* -------------------------------------------------------- ｜  */
+//}

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

-package com.liquidnet.service.consumer.slowly.config;
-
-import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
-import com.liquidnet.service.base.constant.MQConst;
-import com.liquidnet.service.consumer.slowly.receiver.ConsumerGoblinStoreOrderRdsReceiver;
-import lombok.var;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.data.redis.connection.RedisConnectionFactory;
-import org.springframework.data.redis.connection.stream.Consumer;
-import org.springframework.data.redis.connection.stream.MapRecord;
-import org.springframework.data.redis.connection.stream.ReadOffset;
-import org.springframework.data.redis.connection.stream.StreamOffset;
-import org.springframework.data.redis.stream.StreamMessageListenerContainer;
-import org.springframework.data.redis.stream.Subscription;
-
-@Configuration
-public class ConsumerGoblinStoreOrderRedisStreamConfig extends RedisStreamConfig {
-    @Autowired
-    ConsumerGoblinStoreOrderRdsReceiver consumerGoblinStoreOrderRdsReceiver;
-
-    /**
-     * 缺票登记
-     *
-     * @param listenerContainer
-     * @param t
-     * @return
-     */
-    private Subscription receiveGoblinStoreOrder(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
-        return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_STORE_ORDER_OPERA.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_STORE_ORDER_OPERA.name() + t)),
-                StreamOffset.create(MQConst.GoblinQueue.GOBLIN_STORE_ORDER_OPERA.getKey(), ReadOffset.lastConsumed()), consumerGoblinStoreOrderRdsReceiver);
-    }
-
-    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
-
-    /* -------------------------------------------------------- ｜ 缺票登记 */
-
-    @Bean
-    public Subscription subscriptionGoblinStoreOrder0(RedisConnectionFactory factory) {
-        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveGoblinStoreOrder(listenerContainer, 0);
-        listenerContainer.start();
-        return subscription;
-    }
-
-//    @Bean
-//    public Subscription subscriptionGoblinStoreOrder1(RedisConnectionFactory factory) {
-//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveGoblinStoreOrder(listenerContainer, 1);
-//        listenerContainer.start();
-//        return subscription;
+//package com.liquidnet.service.consumer.slowly.config;
+//
+//import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+//import com.liquidnet.service.base.constant.MQConst;
+//import com.liquidnet.service.consumer.slowly.receiver.ConsumerGoblinStoreOrderRdsReceiver;
+//import lombok.var;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.context.annotation.Configuration;
+//import org.springframework.data.redis.connection.RedisConnectionFactory;
+//import org.springframework.data.redis.connection.stream.Consumer;
+//import org.springframework.data.redis.connection.stream.MapRecord;
+//import org.springframework.data.redis.connection.stream.ReadOffset;
+//import org.springframework.data.redis.connection.stream.StreamOffset;
+//import org.springframework.data.redis.stream.StreamMessageListenerContainer;
+//import org.springframework.data.redis.stream.Subscription;
+//
+//@Configuration
+//public class ConsumerGoblinStoreOrderRedisStreamConfig extends RedisStreamConfig {
+//    @Autowired
+//    ConsumerGoblinStoreOrderRdsReceiver consumerGoblinStoreOrderRdsReceiver;
+//
+//    /**
+//     * 缺票登记
+//     *
+//     * @param listenerContainer
+//     * @param t
+//     * @return
+//     */
+//    private Subscription receiveGoblinStoreOrder(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
+//        return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_STORE_ORDER_OPERA.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_STORE_ORDER_OPERA.name() + t)),
+//                StreamOffset.create(MQConst.GoblinQueue.GOBLIN_STORE_ORDER_OPERA.getKey(), ReadOffset.lastConsumed()), consumerGoblinStoreOrderRdsReceiver);
 //    }
 //
+//    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
+//
+//    /* -------------------------------------------------------- ｜ 缺票登记 */
+//
 //    @Bean
-//    public Subscription subscriptionGoblinStoreOrder2(RedisConnectionFactory factory) {
+//    public Subscription subscriptionGoblinStoreOrder0(RedisConnectionFactory factory) {
 //        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveGoblinStoreOrder(listenerContainer, 2);
+//        var subscription = receiveGoblinStoreOrder(listenerContainer, 0);
 //        listenerContainer.start();
 //        return subscription;
 //    }
-
-    /* -------------------------------------------------------- ｜  */
-}
+//
+////    @Bean
+////    public Subscription subscriptionGoblinStoreOrder1(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveGoblinStoreOrder(listenerContainer, 1);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+////
+////    @Bean
+////    public Subscription subscriptionGoblinStoreOrder2(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveGoblinStoreOrder(listenerContainer, 2);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+//
+//    /* -------------------------------------------------------- ｜  */
+//}

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

-package com.liquidnet.service.consumer.slowly.config;
-
-import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
-import com.liquidnet.service.base.constant.MQConst;
-import com.liquidnet.service.consumer.slowly.receiver.ConsumerGoblinUserOrderRdsReceiver;
-import lombok.var;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.data.redis.connection.RedisConnectionFactory;
-import org.springframework.data.redis.connection.stream.Consumer;
-import org.springframework.data.redis.connection.stream.MapRecord;
-import org.springframework.data.redis.connection.stream.ReadOffset;
-import org.springframework.data.redis.connection.stream.StreamOffset;
-import org.springframework.data.redis.stream.StreamMessageListenerContainer;
-import org.springframework.data.redis.stream.Subscription;
-
-@Configuration
-public class ConsumerGoblinUserOrderRedisStreamConfig extends RedisStreamConfig {
-    @Autowired
-    ConsumerGoblinUserOrderRdsReceiver consumerGoblinUserOrderRdsReceiver;
-
-    /**
-     * 缺票登记
-     *
-     * @param listenerContainer
-     * @param t
-     * @return
-     */
-    private Subscription receiveGoblinUserOrder(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
-        return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_USER_ORDER_OPERA.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_USER_ORDER_OPERA.name() + t)),
-                StreamOffset.create(MQConst.GoblinQueue.GOBLIN_USER_ORDER_OPERA.getKey(), ReadOffset.lastConsumed()), consumerGoblinUserOrderRdsReceiver);
-    }
-
-    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
-
-    /* -------------------------------------------------------- ｜ 缺票登记 */
-
-    @Bean
-    public Subscription subscriptionGoblinUserOrder0(RedisConnectionFactory factory) {
-        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveGoblinUserOrder(listenerContainer, 0);
-        listenerContainer.start();
-        return subscription;
-    }
-
-//    @Bean
-//    public Subscription subscriptionGoblinUserOrder1(RedisConnectionFactory factory) {
-//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveGoblinUserOrder(listenerContainer, 1);
-//        listenerContainer.start();
-//        return subscription;
+//package com.liquidnet.service.consumer.slowly.config;
+//
+//import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+//import com.liquidnet.service.base.constant.MQConst;
+//import com.liquidnet.service.consumer.slowly.receiver.ConsumerGoblinUserOrderRdsReceiver;
+//import lombok.var;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.context.annotation.Configuration;
+//import org.springframework.data.redis.connection.RedisConnectionFactory;
+//import org.springframework.data.redis.connection.stream.Consumer;
+//import org.springframework.data.redis.connection.stream.MapRecord;
+//import org.springframework.data.redis.connection.stream.ReadOffset;
+//import org.springframework.data.redis.connection.stream.StreamOffset;
+//import org.springframework.data.redis.stream.StreamMessageListenerContainer;
+//import org.springframework.data.redis.stream.Subscription;
+//
+//@Configuration
+//public class ConsumerGoblinUserOrderRedisStreamConfig extends RedisStreamConfig {
+//    @Autowired
+//    ConsumerGoblinUserOrderRdsReceiver consumerGoblinUserOrderRdsReceiver;
+//
+//    /**
+//     * 缺票登记
+//     *
+//     * @param listenerContainer
+//     * @param t
+//     * @return
+//     */
+//    private Subscription receiveGoblinUserOrder(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
+//        return listenerContainer.receiveAutoAck(Consumer.from(MQConst.GoblinQueue.GOBLIN_USER_ORDER_OPERA.getGroup(), getConsumerName(MQConst.GoblinQueue.GOBLIN_USER_ORDER_OPERA.name() + t)),
+//                StreamOffset.create(MQConst.GoblinQueue.GOBLIN_USER_ORDER_OPERA.getKey(), ReadOffset.lastConsumed()), consumerGoblinUserOrderRdsReceiver);
 //    }
 //
+//    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
+//
+//    /* -------------------------------------------------------- ｜ 缺票登记 */
+//
 //    @Bean
-//    public Subscription subscriptionGoblinUserOrder2(RedisConnectionFactory factory) {
+//    public Subscription subscriptionGoblinUserOrder0(RedisConnectionFactory factory) {
 //        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveGoblinUserOrder(listenerContainer, 2);
+//        var subscription = receiveGoblinUserOrder(listenerContainer, 0);
 //        listenerContainer.start();
 //        return subscription;
 //    }
-
-    /* -------------------------------------------------------- ｜  */
-}
+//
+////    @Bean
+////    public Subscription subscriptionGoblinUserOrder1(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveGoblinUserOrder(listenerContainer, 1);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+////
+////    @Bean
+////    public Subscription subscriptionGoblinUserOrder2(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveGoblinUserOrder(listenerContainer, 2);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+//
+//    /* -------------------------------------------------------- ｜  */
+//}

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

-package com.liquidnet.service.consumer.slowly.config;
-
-import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
-import com.liquidnet.service.consumer.slowly.receiver.ConsumerKylinSqlOrderWithdrawRdsReceiver;
-import lombok.var;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.data.redis.connection.RedisConnectionFactory;
-import org.springframework.data.redis.connection.stream.Consumer;
-import org.springframework.data.redis.connection.stream.MapRecord;
-import org.springframework.data.redis.connection.stream.ReadOffset;
-import org.springframework.data.redis.connection.stream.StreamOffset;
-import org.springframework.data.redis.stream.StreamMessageListenerContainer;
-import org.springframework.data.redis.stream.Subscription;
-
-import static com.liquidnet.service.base.constant.MQConst.KylinQueue.SQL_ORDER_WITHDRAW;
-
-@Configuration
-public class ConsumerKylinSqlOrderWithdrawRedisStreamConfig extends RedisStreamConfig {
-    @Autowired
-    ConsumerKylinSqlOrderWithdrawRdsReceiver consumerKylinSqlOrderWithdrawRdsReceiver;
-
-    /**
-     * 订单申请撤回
-     *
-     * @param listenerContainer
-     * @param t
-     * @return
-     */
-    private Subscription receiveSqlOrderWithdraw(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
-        return listenerContainer.receiveAutoAck(Consumer.from(SQL_ORDER_WITHDRAW.getGroup(), getConsumerName(SQL_ORDER_WITHDRAW.name() + t)),
-                StreamOffset.create(SQL_ORDER_WITHDRAW.getKey(), ReadOffset.lastConsumed()), consumerKylinSqlOrderWithdrawRdsReceiver);
-    }
-
-    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
-
-    /* -------------------------------------------------------- ｜ 订单申请撤回 */
-
-    @Bean
-    public Subscription subscriptionSqlOrderWithdraw0(RedisConnectionFactory factory) {
-        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveSqlOrderWithdraw(listenerContainer, 0);
-        listenerContainer.start();
-        return subscription;
-    }
-
-//    @Bean
-//    public Subscription subscriptionSqlOrderWithdraw1(RedisConnectionFactory factory) {
-//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveSqlOrderWithdraw(listenerContainer, 1);
-//        listenerContainer.start();
-//        return subscription;
-//    }
+//package com.liquidnet.service.consumer.slowly.config;
 //
-//    @Bean
-//    public Subscription subscriptionSqlOrderWithdraw2(RedisConnectionFactory factory) {
-//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveSqlOrderWithdraw(listenerContainer, 2);
-//        listenerContainer.start();
-//        return subscription;
-//    }
-
-//    @Bean
-//    public Subscription subscriptionSqlOrderWithdraw3(RedisConnectionFactory factory) {
-//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveSqlOrderWithdraw(listenerContainer, 3);
-//        listenerContainer.start();
-//        return subscription;
+//import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+//import com.liquidnet.service.consumer.slowly.receiver.ConsumerKylinSqlOrderWithdrawRdsReceiver;
+//import lombok.var;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.context.annotation.Configuration;
+//import org.springframework.data.redis.connection.RedisConnectionFactory;
+//import org.springframework.data.redis.connection.stream.Consumer;
+//import org.springframework.data.redis.connection.stream.MapRecord;
+//import org.springframework.data.redis.connection.stream.ReadOffset;
+//import org.springframework.data.redis.connection.stream.StreamOffset;
+//import org.springframework.data.redis.stream.StreamMessageListenerContainer;
+//import org.springframework.data.redis.stream.Subscription;
+//
+//import static com.liquidnet.service.base.constant.MQConst.KylinQueue.SQL_ORDER_WITHDRAW;
+//
+//@Configuration
+//public class ConsumerKylinSqlOrderWithdrawRedisStreamConfig extends RedisStreamConfig {
+//    @Autowired
+//    ConsumerKylinSqlOrderWithdrawRdsReceiver consumerKylinSqlOrderWithdrawRdsReceiver;
+//
+//    /**
+//     * 订单申请撤回
+//     *
+//     * @param listenerContainer
+//     * @param t
+//     * @return
+//     */
+//    private Subscription receiveSqlOrderWithdraw(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
+//        return listenerContainer.receiveAutoAck(Consumer.from(SQL_ORDER_WITHDRAW.getGroup(), getConsumerName(SQL_ORDER_WITHDRAW.name() + t)),
+//                StreamOffset.create(SQL_ORDER_WITHDRAW.getKey(), ReadOffset.lastConsumed()), consumerKylinSqlOrderWithdrawRdsReceiver);
 //    }
 //
+//    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
+//
+//    /* -------------------------------------------------------- ｜ 订单申请撤回 */
+//
 //    @Bean
-//    public Subscription subscriptionSqlOrderWithdraw4(RedisConnectionFactory factory) {
+//    public Subscription subscriptionSqlOrderWithdraw0(RedisConnectionFactory factory) {
 //        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveSqlOrderWithdraw(listenerContainer, 4);
+//        var subscription = receiveSqlOrderWithdraw(listenerContainer, 0);
 //        listenerContainer.start();
 //        return subscription;
 //    }
-
-    /* -------------------------------------------------------- ｜  */
-}
+//
+////    @Bean
+////    public Subscription subscriptionSqlOrderWithdraw1(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveSqlOrderWithdraw(listenerContainer, 1);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+////
+////    @Bean
+////    public Subscription subscriptionSqlOrderWithdraw2(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveSqlOrderWithdraw(listenerContainer, 2);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+//
+////    @Bean
+////    public Subscription subscriptionSqlOrderWithdraw3(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveSqlOrderWithdraw(listenerContainer, 3);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+////
+////    @Bean
+////    public Subscription subscriptionSqlOrderWithdraw4(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveSqlOrderWithdraw(listenerContainer, 4);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+//
+//    /* -------------------------------------------------------- ｜  */
+//}

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

-package com.liquidnet.service.consumer.slowly.config;
-
-import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
-import com.liquidnet.service.consumer.slowly.receiver.ConsumerKylinSqlPerformanceLackRdsReceiver;
-import lombok.var;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.data.redis.connection.RedisConnectionFactory;
-import org.springframework.data.redis.connection.stream.Consumer;
-import org.springframework.data.redis.connection.stream.MapRecord;
-import org.springframework.data.redis.connection.stream.ReadOffset;
-import org.springframework.data.redis.connection.stream.StreamOffset;
-import org.springframework.data.redis.stream.StreamMessageListenerContainer;
-import org.springframework.data.redis.stream.Subscription;
-
-import static com.liquidnet.service.base.constant.MQConst.KylinQueue.SQL_PERFORMANCE_LACK;
-
-@Configuration
-public class ConsumerKylinSqlPerformanceLackRedisStreamConfig extends RedisStreamConfig {
-    @Autowired
-    ConsumerKylinSqlPerformanceLackRdsReceiver consumerKylinSqlPerformanceLackRdsReceiver;
-
-    /**
-     * 缺票登记
-     *
-     * @param listenerContainer
-     * @param t
-     * @return
-     */
-    private Subscription receiveSqlPerformanceLack(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
-        return listenerContainer.receiveAutoAck(Consumer.from(SQL_PERFORMANCE_LACK.getGroup(), getConsumerName(SQL_PERFORMANCE_LACK.name() + t)),
-                StreamOffset.create(SQL_PERFORMANCE_LACK.getKey(), ReadOffset.lastConsumed()), consumerKylinSqlPerformanceLackRdsReceiver);
-    }
-
-    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
-
-    /* -------------------------------------------------------- ｜ 缺票登记 */
-
-    @Bean
-    public Subscription subscriptionSqlPerformanceLack0(RedisConnectionFactory factory) {
-        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveSqlPerformanceLack(listenerContainer, 0);
-        listenerContainer.start();
-        return subscription;
-    }
-
-    /* -------------------------------------------------------- ｜  */
-}
+//package com.liquidnet.service.consumer.slowly.config;
+//
+//import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+//import com.liquidnet.service.consumer.slowly.receiver.ConsumerKylinSqlPerformanceLackRdsReceiver;
+//import lombok.var;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.context.annotation.Configuration;
+//import org.springframework.data.redis.connection.RedisConnectionFactory;
+//import org.springframework.data.redis.connection.stream.Consumer;
+//import org.springframework.data.redis.connection.stream.MapRecord;
+//import org.springframework.data.redis.connection.stream.ReadOffset;
+//import org.springframework.data.redis.connection.stream.StreamOffset;
+//import org.springframework.data.redis.stream.StreamMessageListenerContainer;
+//import org.springframework.data.redis.stream.Subscription;
+//
+//import static com.liquidnet.service.base.constant.MQConst.KylinQueue.SQL_PERFORMANCE_LACK;
+//
+//@Configuration
+//public class ConsumerKylinSqlPerformanceLackRedisStreamConfig extends RedisStreamConfig {
+//    @Autowired
+//    ConsumerKylinSqlPerformanceLackRdsReceiver consumerKylinSqlPerformanceLackRdsReceiver;
+//
+//    /**
+//     * 缺票登记
+//     *
+//     * @param listenerContainer
+//     * @param t
+//     * @return
+//     */
+//    private Subscription receiveSqlPerformanceLack(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
+//        return listenerContainer.receiveAutoAck(Consumer.from(SQL_PERFORMANCE_LACK.getGroup(), getConsumerName(SQL_PERFORMANCE_LACK.name() + t)),
+//                StreamOffset.create(SQL_PERFORMANCE_LACK.getKey(), ReadOffset.lastConsumed()), consumerKylinSqlPerformanceLackRdsReceiver);
+//    }
+//
+//    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
+//
+//    /* -------------------------------------------------------- ｜ 缺票登记 */
+//
+//    @Bean
+//    public Subscription subscriptionSqlPerformanceLack0(RedisConnectionFactory factory) {
+//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+//        var subscription = receiveSqlPerformanceLack(listenerContainer, 0);
+//        listenerContainer.start();
+//        return subscription;
+//    }
+//
+//    /* -------------------------------------------------------- ｜  */
+//}

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

-package com.liquidnet.service.consumer.slowly.config;
-
-import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
-import com.liquidnet.service.consumer.slowly.receiver.ConsumerKylinTransferRdsReceiver;
-import lombok.var;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.data.redis.connection.RedisConnectionFactory;
-import org.springframework.data.redis.connection.stream.Consumer;
-import org.springframework.data.redis.connection.stream.MapRecord;
-import org.springframework.data.redis.connection.stream.ReadOffset;
-import org.springframework.data.redis.connection.stream.StreamOffset;
-import org.springframework.data.redis.stream.StreamMessageListenerContainer;
-import org.springframework.data.redis.stream.Subscription;
-
-import static com.liquidnet.service.base.constant.MQConst.KylinQueue.SQL_TRANSFER;
-
-@Configuration
-public class ConsumerKylinSqlTransferRedisStreamConfig extends RedisStreamConfig {
-    @Autowired
-    ConsumerKylinTransferRdsReceiver consumerKylinTransferRdsReceiver;
-
-    /**
-     * 验票更新
-     *
-     * @param listenerContainer
-     * @param t
-     * @return
-     */
-    private Subscription receiveTransfer(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
-        return listenerContainer.receiveAutoAck(Consumer.from(SQL_TRANSFER.getGroup(), getConsumerName(SQL_TRANSFER.name() + t)),
-                StreamOffset.create(SQL_TRANSFER.getKey(), ReadOffset.lastConsumed()), consumerKylinTransferRdsReceiver);
-    }
-
-    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
-
-    /* -------------------------------------------------------- ｜ 验票更新 */
-
-    @Bean
-    public Subscription subscriptionReceiveTransfer0(RedisConnectionFactory factory) {
-        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveTransfer(listenerContainer, 0);
-        listenerContainer.start();
-        return subscription;
-    }
-
-//    @Bean
-//    public Subscription subscriptionReceiveTransfer1(RedisConnectionFactory factory) {
-//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveTransfer(listenerContainer, 1);
-//        listenerContainer.start();
-//        return subscription;
-//    }
+//package com.liquidnet.service.consumer.slowly.config;
 //
-//    @Bean
-//    public Subscription subscriptionReceiveTransfer2(RedisConnectionFactory factory) {
-//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveTransfer(listenerContainer, 2);
-//        listenerContainer.start();
-//        return subscription;
-//    }
-
-//    @Bean
-//    public Subscription subscriptionReceiveTransfer3(RedisConnectionFactory factory) {
-//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveTransfer(listenerContainer, 3);
-//        listenerContainer.start();
-//        return subscription;
+//import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+//import com.liquidnet.service.consumer.slowly.receiver.ConsumerKylinTransferRdsReceiver;
+//import lombok.var;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.context.annotation.Configuration;
+//import org.springframework.data.redis.connection.RedisConnectionFactory;
+//import org.springframework.data.redis.connection.stream.Consumer;
+//import org.springframework.data.redis.connection.stream.MapRecord;
+//import org.springframework.data.redis.connection.stream.ReadOffset;
+//import org.springframework.data.redis.connection.stream.StreamOffset;
+//import org.springframework.data.redis.stream.StreamMessageListenerContainer;
+//import org.springframework.data.redis.stream.Subscription;
+//
+//import static com.liquidnet.service.base.constant.MQConst.KylinQueue.SQL_TRANSFER;
+//
+//@Configuration
+//public class ConsumerKylinSqlTransferRedisStreamConfig extends RedisStreamConfig {
+//    @Autowired
+//    ConsumerKylinTransferRdsReceiver consumerKylinTransferRdsReceiver;
+//
+//    /**
+//     * 验票更新
+//     *
+//     * @param listenerContainer
+//     * @param t
+//     * @return
+//     */
+//    private Subscription receiveTransfer(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
+//        return listenerContainer.receiveAutoAck(Consumer.from(SQL_TRANSFER.getGroup(), getConsumerName(SQL_TRANSFER.name() + t)),
+//                StreamOffset.create(SQL_TRANSFER.getKey(), ReadOffset.lastConsumed()), consumerKylinTransferRdsReceiver);
 //    }
 //
+//    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
+//
+//    /* -------------------------------------------------------- ｜ 验票更新 */
+//
 //    @Bean
-//    public Subscription subscriptionReceiveTransfer4(RedisConnectionFactory factory) {
+//    public Subscription subscriptionReceiveTransfer0(RedisConnectionFactory factory) {
 //        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveTransfer(listenerContainer, 4);
+//        var subscription = receiveTransfer(listenerContainer, 0);
 //        listenerContainer.start();
 //        return subscription;
 //    }
-
-    /* -------------------------------------------------------- ｜  */
-}
+//
+////    @Bean
+////    public Subscription subscriptionReceiveTransfer1(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveTransfer(listenerContainer, 1);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+////
+////    @Bean
+////    public Subscription subscriptionReceiveTransfer2(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveTransfer(listenerContainer, 2);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+//
+////    @Bean
+////    public Subscription subscriptionReceiveTransfer3(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveTransfer(listenerContainer, 3);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+////
+////    @Bean
+////    public Subscription subscriptionReceiveTransfer4(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveTransfer(listenerContainer, 4);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+//
+//    /* -------------------------------------------------------- ｜  */
+//}

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

-package com.liquidnet.service.consumer.slowly.config;
-
-import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
-import com.liquidnet.service.consumer.slowly.receiver.ConsumerKylinTransferResultRdsReceiver;
-import lombok.var;
-import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-import org.springframework.data.redis.connection.RedisConnectionFactory;
-import org.springframework.data.redis.connection.stream.Consumer;
-import org.springframework.data.redis.connection.stream.MapRecord;
-import org.springframework.data.redis.connection.stream.ReadOffset;
-import org.springframework.data.redis.connection.stream.StreamOffset;
-import org.springframework.data.redis.stream.StreamMessageListenerContainer;
-import org.springframework.data.redis.stream.Subscription;
-
-import static com.liquidnet.service.base.constant.MQConst.KylinQueue.SQL_TRANSFER_RESULT;
-
-@Configuration
-public class ConsumerKylinSqlTransferResultRedisStreamConfig extends RedisStreamConfig {
-    @Autowired
-    ConsumerKylinTransferResultRdsReceiver consumerKylinTransferResultRdsReceiver;
-
-    /**
-     * 验票更新
-     *
-     * @param listenerContainer
-     * @param t
-     * @return
-     */
-    private Subscription receiveTransferResult(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
-        return listenerContainer.receiveAutoAck(Consumer.from(SQL_TRANSFER_RESULT.getGroup(), getConsumerName(SQL_TRANSFER_RESULT.name() + t)),
-                StreamOffset.create(SQL_TRANSFER_RESULT.getKey(), ReadOffset.lastConsumed()), consumerKylinTransferResultRdsReceiver);
-    }
-
-    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
-
-    /* -------------------------------------------------------- ｜ 验票更新 */
-
-    @Bean
-    public Subscription subscriptionReceiveTransferResult0(RedisConnectionFactory factory) {
-        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-        var subscription = receiveTransferResult(listenerContainer, 0);
-        listenerContainer.start();
-        return subscription;
-    }
-
-//    @Bean
-//    public Subscription subscriptionReceiveTransferResult1(RedisConnectionFactory factory) {
-//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveTransferResult(listenerContainer, 1);
-//        listenerContainer.start();
-//        return subscription;
-//    }
+//package com.liquidnet.service.consumer.slowly.config;
 //
-//    @Bean
-//    public Subscription subscriptionReceiveTransferResult2(RedisConnectionFactory factory) {
-//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveTransferResult(listenerContainer, 2);
-//        listenerContainer.start();
-//        return subscription;
-//    }
-
-//    @Bean
-//    public Subscription subscriptionReceiveTransferResult3(RedisConnectionFactory factory) {
-//        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveTransferResult(listenerContainer, 3);
-//        listenerContainer.start();
-//        return subscription;
+//import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+//import com.liquidnet.service.consumer.slowly.receiver.ConsumerKylinTransferResultRdsReceiver;
+//import lombok.var;
+//import org.springframework.beans.factory.annotation.Autowired;
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.context.annotation.Configuration;
+//import org.springframework.data.redis.connection.RedisConnectionFactory;
+//import org.springframework.data.redis.connection.stream.Consumer;
+//import org.springframework.data.redis.connection.stream.MapRecord;
+//import org.springframework.data.redis.connection.stream.ReadOffset;
+//import org.springframework.data.redis.connection.stream.StreamOffset;
+//import org.springframework.data.redis.stream.StreamMessageListenerContainer;
+//import org.springframework.data.redis.stream.Subscription;
+//
+//import static com.liquidnet.service.base.constant.MQConst.KylinQueue.SQL_TRANSFER_RESULT;
+//
+//@Configuration
+//public class ConsumerKylinSqlTransferResultRedisStreamConfig extends RedisStreamConfig {
+//    @Autowired
+//    ConsumerKylinTransferResultRdsReceiver consumerKylinTransferResultRdsReceiver;
+//
+//    /**
+//     * 验票更新
+//     *
+//     * @param listenerContainer
+//     * @param t
+//     * @return
+//     */
+//    private Subscription receiveTransferResult(StreamMessageListenerContainer<String, MapRecord<String, String, String>> listenerContainer, int t) {
+//        return listenerContainer.receiveAutoAck(Consumer.from(SQL_TRANSFER_RESULT.getGroup(), getConsumerName(SQL_TRANSFER_RESULT.name() + t)),
+//                StreamOffset.create(SQL_TRANSFER_RESULT.getKey(), ReadOffset.lastConsumed()), consumerKylinTransferResultRdsReceiver);
 //    }
 //
+//    /* —————————————————————————— ｜ —————————————————————————— ｜ —————————————————————————— */
+//
+//    /* -------------------------------------------------------- ｜ 验票更新 */
+//
 //    @Bean
-//    public Subscription subscriptionReceiveTransferResult4(RedisConnectionFactory factory) {
+//    public Subscription subscriptionReceiveTransferResult0(RedisConnectionFactory factory) {
 //        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
-//        var subscription = receiveTransferResult(listenerContainer, 4);
+//        var subscription = receiveTransferResult(listenerContainer, 0);
 //        listenerContainer.start();
 //        return subscription;
 //    }
-
-    /* -------------------------------------------------------- ｜  */
-}
+//
+////    @Bean
+////    public Subscription subscriptionReceiveTransferResult1(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveTransferResult(listenerContainer, 1);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+////
+////    @Bean
+////    public Subscription subscriptionReceiveTransferResult2(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveTransferResult(listenerContainer, 2);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+//
+////    @Bean
+////    public Subscription subscriptionReceiveTransferResult3(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveTransferResult(listenerContainer, 3);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+////
+////    @Bean
+////    public Subscription subscriptionReceiveTransferResult4(RedisConnectionFactory factory) {
+////        var listenerContainer = this.buildStreamMessageListenerContainer(factory);
+////        var subscription = receiveTransferResult(listenerContainer, 4);
+////        listenerContainer.start();
+////        return subscription;
+////    }
+//
+//    /* -------------------------------------------------------- ｜  */
+//}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/receiver/ConsumerGoblinOrderCloseRdsReceiver.java

-package com.liquidnet.service.consumer.slowly.receiver;
-
-import com.liquidnet.service.base.constant.MQConst;
-import org.springframework.stereotype.Component;
-
-@Component
-public class ConsumerGoblinOrderCloseRdsReceiver extends AbstractSqlRedisReceiver {
-    @Override
-    protected String getRedisStreamKey() {
-        return MQConst.GoblinQueue.GOBLIN_ORDER_CLOSE.getKey();
-    }
-
-    @Override
-    protected String getRedisStreamGroup() {
-        return MQConst.GoblinQueue.GOBLIN_ORDER_CLOSE.getGroup();
-    }
-}
+//package com.liquidnet.service.consumer.slowly.receiver;
+//
+//import com.liquidnet.service.base.constant.MQConst;
+//import org.springframework.stereotype.Component;
+//
+//@Component
+//public class ConsumerGoblinOrderCloseRdsReceiver extends AbstractSqlRedisReceiver {
+//    @Override
+//    protected String getRedisStreamKey() {
+//        return MQConst.GoblinQueue.GOBLIN_ORDER_CLOSE.getKey();
+//    }
+//
+//    @Override
+//    protected String getRedisStreamGroup() {
+//        return MQConst.GoblinQueue.GOBLIN_ORDER_CLOSE.getGroup();
+//    }
+//}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/receiver/ConsumerGoblinSelfMarketRdsReceiver.java

-package com.liquidnet.service.consumer.slowly.receiver;
-
-import com.liquidnet.service.base.constant.MQConst;
-import org.springframework.stereotype.Component;
-
-@Component
-public class ConsumerGoblinSelfMarketRdsReceiver extends AbstractSqlRedisReceiver {
-    @Override
-    protected String getRedisStreamKey() {
-        return MQConst.GoblinQueue.GOBLIN_SELF_MARKET.getKey();
-    }
-
-    @Override
-    protected String getRedisStreamGroup() {
-        return MQConst.GoblinQueue.GOBLIN_SELF_MARKET.getGroup();
-    }
-}
+//package com.liquidnet.service.consumer.slowly.receiver;
+//
+//import com.liquidnet.service.base.constant.MQConst;
+//import org.springframework.stereotype.Component;
+//
+//@Component
+//public class ConsumerGoblinSelfMarketRdsReceiver extends AbstractSqlRedisReceiver {
+//    @Override
+//    protected String getRedisStreamKey() {
+//        return MQConst.GoblinQueue.GOBLIN_SELF_MARKET.getKey();
+//    }
+//
+//    @Override
+//    protected String getRedisStreamGroup() {
+//        return MQConst.GoblinQueue.GOBLIN_SELF_MARKET.getGroup();
+//    }
+//}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/receiver/ConsumerGoblinShopCartReceiver.java

-package com.liquidnet.service.consumer.slowly.receiver;
-
-import com.liquidnet.service.base.constant.MQConst;
-import org.springframework.stereotype.Component;
-
-@Component
-public class ConsumerGoblinShopCartReceiver extends AbstractSqlRedisReceiver {
-    @Override
-    protected String getRedisStreamKey() {
-        return MQConst.GoblinQueue.GOBLIN_SHOP_CART.getKey();
-    }
-
-    @Override
-    protected String getRedisStreamGroup() {
-        return MQConst.GoblinQueue.GOBLIN_SHOP_CART.getGroup();
-    }
-}
+//package com.liquidnet.service.consumer.slowly.receiver;
+//
+//import com.liquidnet.service.base.constant.MQConst;
+//import org.springframework.stereotype.Component;
+//
+//@Component
+//public class ConsumerGoblinShopCartReceiver extends AbstractSqlRedisReceiver {
+//    @Override
+//    protected String getRedisStreamKey() {
+//        return MQConst.GoblinQueue.GOBLIN_SHOP_CART.getKey();
+//    }
+//
+//    @Override
+//    protected String getRedisStreamGroup() {
+//        return MQConst.GoblinQueue.GOBLIN_SHOP_CART.getGroup();
+//    }
+//}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/receiver/ConsumerGoblinStoreMarketRdsReceiver.java

-package com.liquidnet.service.consumer.slowly.receiver;
-
-import com.liquidnet.service.base.constant.MQConst;
-import org.springframework.stereotype.Component;
-
-@Component
-public class ConsumerGoblinStoreMarketRdsReceiver extends AbstractSqlRedisReceiver {
-    @Override
-    protected String getRedisStreamKey() {
-        return MQConst.GoblinQueue.GOBLIN_STORE_MARKET.getKey();
-    }
-
-    @Override
-    protected String getRedisStreamGroup() {
-        return MQConst.GoblinQueue.GOBLIN_STORE_MARKET.getGroup();
-    }
-}
+//package com.liquidnet.service.consumer.slowly.receiver;
+//
+//import com.liquidnet.service.base.constant.MQConst;
+//import org.springframework.stereotype.Component;
+//
+//@Component
+//public class ConsumerGoblinStoreMarketRdsReceiver extends AbstractSqlRedisReceiver {
+//    @Override
+//    protected String getRedisStreamKey() {
+//        return MQConst.GoblinQueue.GOBLIN_STORE_MARKET.getKey();
+//    }
+//
+//    @Override
+//    protected String getRedisStreamGroup() {
+//        return MQConst.GoblinQueue.GOBLIN_STORE_MARKET.getGroup();
+//    }
+//}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/receiver/ConsumerGoblinStoreOrderRdsReceiver.java

-package com.liquidnet.service.consumer.slowly.receiver;
-
-import com.liquidnet.service.base.constant.MQConst;
-import org.springframework.stereotype.Component;
-
-@Component
-public class ConsumerGoblinStoreOrderRdsReceiver extends AbstractSqlRedisReceiver {
-    @Override
-    protected String getRedisStreamKey() {
-        return MQConst.GoblinQueue.GOBLIN_STORE_ORDER_OPERA.getKey();
-    }
-
-    @Override
-    protected String getRedisStreamGroup() {
-        return MQConst.GoblinQueue.GOBLIN_STORE_ORDER_OPERA.getGroup();
-    }
-}
+//package com.liquidnet.service.consumer.slowly.receiver;
+//
+//import com.liquidnet.service.base.constant.MQConst;
+//import org.springframework.stereotype.Component;
+//
+//@Component
+//public class ConsumerGoblinStoreOrderRdsReceiver extends AbstractSqlRedisReceiver {
+//    @Override
+//    protected String getRedisStreamKey() {
+//        return MQConst.GoblinQueue.GOBLIN_STORE_ORDER_OPERA.getKey();
+//    }
+//
+//    @Override
+//    protected String getRedisStreamGroup() {
+//        return MQConst.GoblinQueue.GOBLIN_STORE_ORDER_OPERA.getGroup();
+//    }
+//}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/receiver/ConsumerGoblinUserOrderRdsReceiver.java

-package com.liquidnet.service.consumer.slowly.receiver;
-
-import com.liquidnet.service.base.constant.MQConst;
-import org.springframework.stereotype.Component;
-
-@Component
-public class ConsumerGoblinUserOrderRdsReceiver extends AbstractSqlRedisReceiver {
-    @Override
-    protected String getRedisStreamKey() {
-        return MQConst.GoblinQueue.GOBLIN_USER_ORDER_OPERA.getKey();
-    }
-
-    @Override
-    protected String getRedisStreamGroup() {
-        return MQConst.GoblinQueue.GOBLIN_USER_ORDER_OPERA.getGroup();
-    }
-}
+//package com.liquidnet.service.consumer.slowly.receiver;
+//
+//import com.liquidnet.service.base.constant.MQConst;
+//import org.springframework.stereotype.Component;
+//
+//@Component
+//public class ConsumerGoblinUserOrderRdsReceiver extends AbstractSqlRedisReceiver {
+//    @Override
+//    protected String getRedisStreamKey() {
+//        return MQConst.GoblinQueue.GOBLIN_USER_ORDER_OPERA.getKey();
+//    }
+//
+//    @Override
+//    protected String getRedisStreamGroup() {
+//        return MQConst.GoblinQueue.GOBLIN_USER_ORDER_OPERA.getGroup();
+//    }
+//}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/receiver/ConsumerKylinSqlOrderWithdrawRdsReceiver.java

-package com.liquidnet.service.consumer.slowly.receiver;
-
-import com.liquidnet.service.base.constant.MQConst;
-import org.springframework.stereotype.Component;
-
-@Component
-public class ConsumerKylinSqlOrderWithdrawRdsReceiver extends AbstractSqlRedisReceiver {
-    @Override
-    protected String getRedisStreamKey() {
-        return MQConst.KylinQueue.SQL_ORDER_WITHDRAW.getKey();
-    }
-
-    @Override
-    protected String getRedisStreamGroup() {
-        return MQConst.KylinQueue.SQL_ORDER_WITHDRAW.getGroup();
-    }
-}
+//package com.liquidnet.service.consumer.slowly.receiver;
+//
+//import com.liquidnet.service.base.constant.MQConst;
+//import org.springframework.stereotype.Component;
+//
+//@Component
+//public class ConsumerKylinSqlOrderWithdrawRdsReceiver extends AbstractSqlRedisReceiver {
+//    @Override
+//    protected String getRedisStreamKey() {
+//        return MQConst.KylinQueue.SQL_ORDER_WITHDRAW.getKey();
+//    }
+//
+//    @Override
+//    protected String getRedisStreamGroup() {
+//        return MQConst.KylinQueue.SQL_ORDER_WITHDRAW.getGroup();
+//    }
+//}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/receiver/ConsumerKylinSqlPerformanceLackRdsReceiver.java

-package com.liquidnet.service.consumer.slowly.receiver;
-
-import com.liquidnet.service.base.constant.MQConst;
-import org.springframework.stereotype.Component;
-
-@Component
-public class ConsumerKylinSqlPerformanceLackRdsReceiver extends AbstractSqlRedisReceiver {
-    @Override
-    protected String getRedisStreamKey() {
-        return MQConst.KylinQueue.SQL_PERFORMANCE_LACK.getKey();
-    }
-
-    @Override
-    protected String getRedisStreamGroup() {
-        return MQConst.KylinQueue.SQL_PERFORMANCE_LACK.getGroup();
-    }
-}
+//package com.liquidnet.service.consumer.slowly.receiver;
+//
+//import com.liquidnet.service.base.constant.MQConst;
+//import org.springframework.stereotype.Component;
+//
+//@Component
+//public class ConsumerKylinSqlPerformanceLackRdsReceiver extends AbstractSqlRedisReceiver {
+//    @Override
+//    protected String getRedisStreamKey() {
+//        return MQConst.KylinQueue.SQL_PERFORMANCE_LACK.getKey();
+//    }
+//
+//    @Override
+//    protected String getRedisStreamGroup() {
+//        return MQConst.KylinQueue.SQL_PERFORMANCE_LACK.getGroup();
+//    }
+//}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/receiver/ConsumerKylinTransferRdsReceiver.java

-package com.liquidnet.service.consumer.slowly.receiver;
-
-import com.liquidnet.service.base.constant.MQConst;
-import org.springframework.stereotype.Component;
-
-@Component
-public class ConsumerKylinTransferRdsReceiver extends AbstractSqlRedisReceiver {
-    @Override
-    protected String getRedisStreamKey() {
-        return MQConst.KylinQueue.SQL_TRANSFER.getKey();
-    }
-
-    @Override
-    protected String getRedisStreamGroup() {
-        return MQConst.KylinQueue.SQL_TRANSFER.getGroup();
-    }
-}
+//package com.liquidnet.service.consumer.slowly.receiver;
+//
+//import com.liquidnet.service.base.constant.MQConst;
+//import org.springframework.stereotype.Component;
+//
+//@Component
+//public class ConsumerKylinTransferRdsReceiver extends AbstractSqlRedisReceiver {
+//    @Override
+//    protected String getRedisStreamKey() {
+//        return MQConst.KylinQueue.SQL_TRANSFER.getKey();
+//    }
+//
+//    @Override
+//    protected String getRedisStreamGroup() {
+//        return MQConst.KylinQueue.SQL_TRANSFER.getGroup();
+//    }
+//}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-slowly/src/main/java/com/liquidnet/service/consumer/slowly/receiver/ConsumerKylinTransferResultRdsReceiver.java

-package com.liquidnet.service.consumer.slowly.receiver;
-
-import com.liquidnet.service.base.constant.MQConst;
-import org.springframework.stereotype.Component;
-
-@Component
-public class ConsumerKylinTransferResultRdsReceiver extends AbstractSqlRedisReceiver {
-    @Override
-    protected String getRedisStreamKey() {
-        return MQConst.KylinQueue.SQL_TRANSFER_RESULT.getKey();
-    }
-
-    @Override
-    protected String getRedisStreamGroup() {
-        return MQConst.KylinQueue.SQL_TRANSFER_RESULT.getGroup();
-    }
-}
+//package com.liquidnet.service.consumer.slowly.receiver;
+//
+//import com.liquidnet.service.base.constant.MQConst;
+//import org.springframework.stereotype.Component;
+//
+//@Component
+//public class ConsumerKylinTransferResultRdsReceiver extends AbstractSqlRedisReceiver {
+//    @Override
+//    protected String getRedisStreamKey() {
+//        return MQConst.KylinQueue.SQL_TRANSFER_RESULT.getKey();
+//    }
+//
+//    @Override
+//    protected String getRedisStreamGroup() {
+//        return MQConst.KylinQueue.SQL_TRANSFER_RESULT.getGroup();
+//    }
+//}