~queue:adam;

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-adam/src/main/java/com/liquidnet/service/consumer/adam/config/ConsumerAdamSqlUcenterRedisStreamConfig.java

-package com.liquidnet.service.consumer.adam.config;
-
-import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
-import com.liquidnet.service.consumer.adam.receiver.ConsumerAdamSqlUCenterRdsReceiver;
-import com.liquidnet.service.consumer.adam.receiver.ConsumerAdamSqlUMemberRdsReceiver;
-import com.liquidnet.service.consumer.adam.receiver.ConsumerAdamSqlURegisterRdsReceiver;
-import lombok.extern.slf4j.Slf4j;
-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;
-
-import static com.liquidnet.service.base.constant.MQConst.AdamQueue;
-
-@Slf4j
-@Configuration
-public class ConsumerAdamSqlUcenterRedisStreamConfig extends RedisStreamConfig {
-    @Autowired
-    StringRedisTemplate stringRedisTemplate;
-    @Autowired
-    ConsumerAdamSqlURegisterRdsReceiver consumerAdamURegisterRdsReceiver;
-    @Autowired
-    ConsumerAdamSqlUCenterRdsReceiver consumerAdamUCenterRdsReceiver;
-    @Autowired
-    ConsumerAdamSqlUMemberRdsReceiver consumerAdamUMemberRdsReceiver;
-
-    @Bean// 用户注册
-    public List<Subscription> subscriptionSqlURegister(RedisConnectionFactory factory) {
-        List<Subscription> subscriptionList = new ArrayList<>();
-        AdamQueue stream = AdamQueue.SQL_UREGISTER;
-        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
-        for (int i = 0; i < 10; 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()), consumerAdamURegisterRdsReceiver
-            ));
-            listenerContainer.start();
-        }
-        return subscriptionList;
-    }
-
-    @Bean// 用户中心
-    public List<Subscription> subscriptionSqlUCenter(RedisConnectionFactory factory) {
-        List<Subscription> subscriptionList = new ArrayList<>();
-        AdamQueue stream = AdamQueue.SQL_UCENTER;
-        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
-        for (int i = 0; i < 10; 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()), consumerAdamUCenterRdsReceiver
-            ));
-            listenerContainer.start();
-        }
-        return subscriptionList;
-    }
-
-    @Bean// 购买会员
-    public List<Subscription> subscriptionSqlUMember(RedisConnectionFactory factory) {
-        List<Subscription> subscriptionList = new ArrayList<>();
-        AdamQueue stream = AdamQueue.SQL_UMEMBER;
-        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
-        for (int i = 0; i < 10; 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()), consumerAdamUMemberRdsReceiver
-            ));
-            listenerContainer.start();
-        }
-        return subscriptionList;
-    }
-}
+//package com.liquidnet.service.consumer.adam.config;
+//
+//import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+//import com.liquidnet.service.consumer.adam.receiver.ConsumerAdamSqlUCenterRdsReceiver;
+//import com.liquidnet.service.consumer.adam.receiver.ConsumerAdamSqlUMemberRdsReceiver;
+//import com.liquidnet.service.consumer.adam.receiver.ConsumerAdamSqlURegisterRdsReceiver;
+//import lombok.extern.slf4j.Slf4j;
+//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;
+//
+//import static com.liquidnet.service.base.constant.MQConst.AdamQueue;
+//
+//@Slf4j
+//@Configuration
+//public class ConsumerAdamSqlUcenterRedisStreamConfig extends RedisStreamConfig {
+//    @Autowired
+//    StringRedisTemplate stringRedisTemplate;
+//    @Autowired
+//    ConsumerAdamSqlURegisterRdsReceiver consumerAdamURegisterRdsReceiver;
+//    @Autowired
+//    ConsumerAdamSqlUCenterRdsReceiver consumerAdamUCenterRdsReceiver;
+//    @Autowired
+//    ConsumerAdamSqlUMemberRdsReceiver consumerAdamUMemberRdsReceiver;
+//
+//    @Bean// 用户注册
+//    public List<Subscription> subscriptionSqlURegister(RedisConnectionFactory factory) {
+//        List<Subscription> subscriptionList = new ArrayList<>();
+//        AdamQueue stream = AdamQueue.SQL_UREGISTER;
+//        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
+//        for (int i = 0; i < 10; 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()), consumerAdamURegisterRdsReceiver
+//            ));
+//            listenerContainer.start();
+//        }
+//        return subscriptionList;
+//    }
+//
+//    @Bean// 用户中心
+//    public List<Subscription> subscriptionSqlUCenter(RedisConnectionFactory factory) {
+//        List<Subscription> subscriptionList = new ArrayList<>();
+//        AdamQueue stream = AdamQueue.SQL_UCENTER;
+//        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
+//        for (int i = 0; i < 10; 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()), consumerAdamUCenterRdsReceiver
+//            ));
+//            listenerContainer.start();
+//        }
+//        return subscriptionList;
+//    }
+//
+//    @Bean// 购买会员
+//    public List<Subscription> subscriptionSqlUMember(RedisConnectionFactory factory) {
+//        List<Subscription> subscriptionList = new ArrayList<>();
+//        AdamQueue stream = AdamQueue.SQL_UMEMBER;
+//        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
+//        for (int i = 0; i < 10; 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()), consumerAdamUMemberRdsReceiver
+//            ));
+//            listenerContainer.start();
+//        }
+//        return subscriptionList;
+//    }
+//}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-adam/src/main/java/com/liquidnet/service/consumer/adam/receiver/ConsumerAdamSqlUCenterRdsReceiver.java

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

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-adam/src/main/java/com/liquidnet/service/consumer/adam/receiver/ConsumerAdamSqlUMemberRdsReceiver.java

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

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-adam/src/main/java/com/liquidnet/service/consumer/adam/receiver/ConsumerAdamSqlURegisterRdsReceiver.java

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

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

@@ -41,6 +41,12 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
     ConsumerGoblinSqlCouponRdsReceiver consumerGoblinSqlCouponRdsReceiver;
     @Autowired
     ConsumerGoblinSqlArtworkGenRdsReceiver consumerGoblinSqlArtworkGenRdsReceiver;
+    @Autowired
+    ConsumerAdamSqlURegisterRdsReceiver consumerAdamURegisterRdsReceiver;
+    @Autowired
+    ConsumerAdamSqlUCenterRdsReceiver consumerAdamUCenterRdsReceiver;
+    @Autowired
+    ConsumerAdamSqlUMemberRdsReceiver consumerAdamUMemberRdsReceiver;
 
 //    @Bean
 //    public List<Subscription> subscriptionSQL0(RedisConnectionFactory factory) {
@@ -142,4 +148,52 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
         }
         return subscriptionList;
     }
+
+    @Bean// 用户注册
+    public List<Subscription> subscriptionAdamSqlURegister(RedisConnectionFactory factory) {
+        List<Subscription> subscriptionList = new ArrayList<>();
+        MQConst.AdamQueue stream = MQConst.AdamQueue.SQL_UREGISTER;
+        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
+        for (int i = 0; i < 10; 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()), consumerAdamURegisterRdsReceiver
+            ));
+            listenerContainer.start();
+        }
+        return subscriptionList;
+    }
+
+    @Bean// 用户中心
+    public List<Subscription> subscriptionAdamSqlUCenter(RedisConnectionFactory factory) {
+        List<Subscription> subscriptionList = new ArrayList<>();
+        MQConst.AdamQueue stream = MQConst.AdamQueue.SQL_UCENTER;
+        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
+        for (int i = 0; i < 10; 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()), consumerAdamUCenterRdsReceiver
+            ));
+            listenerContainer.start();
+        }
+        return subscriptionList;
+    }
+
+    @Bean// 购买会员
+    public List<Subscription> subscriptionAdamSqlUMember(RedisConnectionFactory factory) {
+        List<Subscription> subscriptionList = new ArrayList<>();
+        MQConst.AdamQueue stream = MQConst.AdamQueue.SQL_UMEMBER;
+        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
+        for (int i = 0; i < 10; 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()), consumerAdamUMemberRdsReceiver
+            ));
+            listenerContainer.start();
+        }
+        return subscriptionList;
+    }
 }

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

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

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

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

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

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