~queue:opt;

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

@@ -32,23 +32,23 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
     ConsumerCommonSQL0Receiver consumerCommonSQL0Receiver;
 
     @Autowired
-    ConsumerGoblinNftOrderRdsReceiver consumerGoblinNftOrderRdsReceiver;
+    ConsumerGoblinNftOrderReceiver consumerGoblinNftOrderReceiver;
     @Autowired
-    ConsumerGoblinSqlStoreRdsReceiver consumerGoblinSqlStoreRdsReceiver;
+    ConsumerGoblinSqlStoreReceiver consumerGoblinSqlStoreReceiver;
     @Autowired
-    ConsumerGoblinSqlGoodsRdsReceiver consumerGoblinSqlGoodsRdsReceiver;
+    ConsumerGoblinSqlGoodsReceiver consumerGoblinSqlGoodsReceiver;
     @Autowired
-    ConsumerGoblinSqlCouponRdsReceiver consumerGoblinSqlCouponRdsReceiver;
+    ConsumerGoblinSqlCouponReceiver consumerGoblinSqlCouponReceiver;
     @Autowired
-    ConsumerGoblinSqlArtworkGenRdsReceiver consumerGoblinSqlArtworkGenRdsReceiver;
+    ConsumerGoblinSqlArtworkGenReceiver consumerGoblinSqlArtworkGenReceiver;
     @Autowired
-    ConsumerAdamSqlURegisterRdsReceiver consumerAdamURegisterRdsReceiver;
+    ConsumerAdamSqlURegisterReceiver consumerAdamURegisterRdsReceiver;
     @Autowired
-    ConsumerAdamSqlUCenterRdsReceiver consumerAdamUCenterRdsReceiver;
+    ConsumerAdamSqlUCenterReceiver consumerAdamUCenterRdsReceiver;
     @Autowired
-    ConsumerAdamSqlUMemberRdsReceiver consumerAdamUMemberRdsReceiver;
+    ConsumerAdamSqlUMemberReceiver consumerAdamUMemberRdsReceiver;
     @Autowired
-    ConsumerKylinSqlStationRdsReceiver consumerKylinSqlStationRdsReceiver;
+    ConsumerKylinSqlStationReceiver consumerKylinSqlStationReceiver;
 
 //    @Bean
 //    public List<Subscription> subscriptionSQL0(RedisConnectionFactory factory) {
@@ -80,7 +80,7 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
             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()), consumerGoblinNftOrderRdsReceiver
+                    StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerGoblinNftOrderReceiver
             ));
             listenerContainer.start();
         }
@@ -96,7 +96,7 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
             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()), consumerGoblinSqlStoreRdsReceiver
+                    StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerGoblinSqlStoreReceiver
             ));
             listenerContainer.start();
         }
@@ -112,7 +112,7 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
             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()), consumerGoblinSqlGoodsRdsReceiver
+                    StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerGoblinSqlGoodsReceiver
             ));
             listenerContainer.start();
         }
@@ -128,7 +128,7 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
             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()), consumerGoblinSqlCouponRdsReceiver
+                    StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerGoblinSqlCouponReceiver
             ));
             listenerContainer.start();
         }
@@ -144,7 +144,7 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
             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()), consumerGoblinSqlArtworkGenRdsReceiver
+                    StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerGoblinSqlArtworkGenReceiver
             ));
             listenerContainer.start();
         }
@@ -208,7 +208,7 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
             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()), consumerKylinSqlStationRdsReceiver
+                    StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), consumerKylinSqlStationReceiver
             ));
             listenerContainer.start();
         }

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/ConsumerAdamSqlUCenterRdsReceiver.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/ConsumerAdamSqlUCenterReceiver.java

@@ -4,7 +4,7 @@ import com.liquidnet.service.base.constant.MQConst;
 import org.springframework.stereotype.Component;
 
 @Component
-public class ConsumerAdamSqlUCenterRdsReceiver extends AbstractSqlRedisReceiver {
+public class ConsumerAdamSqlUCenterReceiver extends AbstractSqlRedisReceiver {
     @Override
     protected String getRedisStreamKey() {
         return MQConst.AdamQueue.SQL_UCENTER.getKey();

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/ConsumerAdamSqlUMemberRdsReceiver.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/ConsumerAdamSqlUMemberReceiver.java

@@ -4,7 +4,7 @@ import com.liquidnet.service.base.constant.MQConst;
 import org.springframework.stereotype.Component;
 
 @Component
-public class ConsumerAdamSqlUMemberRdsReceiver extends AbstractSqlRedisReceiver {
+public class ConsumerAdamSqlUMemberReceiver extends AbstractSqlRedisReceiver {
     @Override
     protected String getRedisStreamKey() {
         return MQConst.AdamQueue.SQL_UMEMBER.getKey();

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/ConsumerAdamSqlURegisterRdsReceiver.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/ConsumerAdamSqlURegisterReceiver.java

@@ -4,7 +4,7 @@ import com.liquidnet.service.base.constant.MQConst;
 import org.springframework.stereotype.Component;
 
 @Component
-public class ConsumerAdamSqlURegisterRdsReceiver extends AbstractSqlRedisReceiver {
+public class ConsumerAdamSqlURegisterReceiver extends AbstractSqlRedisReceiver {
     @Override
     protected String getRedisStreamKey() {
         return MQConst.AdamQueue.SQL_UREGISTER.getKey();

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/ConsumerGoblinNftOrderRdsReceiver.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/ConsumerGoblinNftOrderReceiver.java

@@ -4,7 +4,7 @@ import com.liquidnet.service.base.constant.MQConst;
 import org.springframework.stereotype.Component;
 
 @Component
-public class ConsumerGoblinNftOrderRdsReceiver extends AbstractSqlRedisReceiver {
+public class ConsumerGoblinNftOrderReceiver extends AbstractSqlRedisReceiver {
     @Override
     protected String getRedisStreamKey() {
         return MQConst.GoblinQueue.GOBLIN_NFT_ORDER.getKey();

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/ConsumerGoblinSqlArtworkGenRdsReceiver.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/ConsumerGoblinSqlArtworkGenReceiver.java

@@ -4,7 +4,7 @@ import com.liquidnet.service.base.constant.MQConst;
 import org.springframework.stereotype.Component;
 
 @Component
-public class ConsumerGoblinSqlArtworkGenRdsReceiver extends AbstractSqlRedisReceiver {
+public class ConsumerGoblinSqlArtworkGenReceiver extends AbstractSqlRedisReceiver {
     @Override
     protected String getRedisStreamKey() {
         return MQConst.GoblinQueue.SQL_ARTWORK_GEN.getKey();

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/ConsumerGoblinSqlCouponRdsReceiver.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/ConsumerGoblinSqlCouponReceiver.java

@@ -4,7 +4,7 @@ import com.liquidnet.service.base.constant.MQConst;
 import org.springframework.stereotype.Component;
 
 @Component
-public class ConsumerGoblinSqlCouponRdsReceiver extends AbstractSqlRedisReceiver {
+public class ConsumerGoblinSqlCouponReceiver extends AbstractSqlRedisReceiver {
     @Override
     protected String getRedisStreamKey() {
         return MQConst.GoblinQueue.SQL_COUPON.getKey();

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/ConsumerGoblinSqlGoodsRdsReceiver.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/ConsumerGoblinSqlGoodsReceiver.java

@@ -4,7 +4,7 @@ import com.liquidnet.service.base.constant.MQConst;
 import org.springframework.stereotype.Component;
 
 @Component
-public class ConsumerGoblinSqlGoodsRdsReceiver extends AbstractSqlRedisReceiver {
+public class ConsumerGoblinSqlGoodsReceiver extends AbstractSqlRedisReceiver {
     @Override
     protected String getRedisStreamKey() {
         return MQConst.GoblinQueue.SQL_GOODS.getKey();

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/ConsumerGoblinSqlStoreRdsReceiver.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/ConsumerGoblinSqlStoreReceiver.java

@@ -4,7 +4,7 @@ import com.liquidnet.service.base.constant.MQConst;
 import org.springframework.stereotype.Component;
 
 @Component
-public class ConsumerGoblinSqlStoreRdsReceiver extends AbstractSqlRedisReceiver {
+public class ConsumerGoblinSqlStoreReceiver extends AbstractSqlRedisReceiver {
     @Override
     protected String getRedisStreamKey() {
         return MQConst.GoblinQueue.SQL_STORE.getKey();

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/ConsumerKylinSqlStationRdsReceiver.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-base/src/main/java/com/liquidnet/service/consumer/base/receiver/ConsumerKylinSqlStationReceiver.java

@@ -4,7 +4,7 @@ import com.liquidnet.service.base.constant.MQConst;
 import org.springframework.stereotype.Component;
 
 @Component
-public class ConsumerKylinSqlStationRdsReceiver extends AbstractSqlRedisReceiver {
+public class ConsumerKylinSqlStationReceiver extends AbstractSqlRedisReceiver {
     @Override
     protected String getRedisStreamKey() {
         return MQConst.KylinQueue.SQL_STATION.getKey();