消费NFT注掉已迁移队列

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

@@ -19,9 +19,6 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
     @Autowired
     ConsumerCommonSQL0Receiver consumerCommonSQL0Receiver;
 
-//    @Autowired
-//    ConsumerGoblinNftOrderRdsReceiver consumerGoblinNftOrderRdsReceiver;
-
 //    @Bean
 //    public List<Subscription> subscriptionSQL0(RedisConnectionFactory factory) {
 //        List<Subscription> subscriptionList = new ArrayList<>();
@@ -37,20 +34,4 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
 //        }
 //        return subscriptionList;
 //    }
-
-//    @Bean// goblin NFT订单
-//    public List<Subscription> subscriptionSqlNftOrder(RedisConnectionFactory factory) {
-//        List<Subscription> subscriptionList = new ArrayList<>();
-//        MQConst.GoblinQueue stream = MQConst.GoblinQueue.GOBLIN_NFT_ORDER;
-//        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
-//        for (int i = 0; i < 20; 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()), consumerGoblinNftOrderRdsReceiver
-//            ));
-//            listenerContainer.start();
-//        }
-//        return subscriptionList;
-//    }
 }

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-nft/src/main/java/com/liquidnet/service/consumer/nft/config/ConsumerGalaxyJsonNftPublishAndBuyConfig.java

-package com.liquidnet.service.consumer.nft.config;
-
-import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
-import com.liquidnet.service.base.constant.MQConst;
-import com.liquidnet.service.consumer.nft.receiver.ConsumerGalaxyJsonNftPublishAndBuyReceiver;
-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;
-
-/**
- * @author AnJiabin <anjiabin@zhengzai.tv>
- * @version V1.0
- * @Description: 区块链nft订单相关
- * @class: ConsumerSqlNftOrderInfoConfig
- * @Package com.liquidnet.service.consumer.galaxy.config
- * @Copyright: LightNet @ Copyright (c) 2022
- * @date 2022/3/25 14:45
- */
-@Configuration
-public class ConsumerGalaxyJsonNftPublishAndBuyConfig extends RedisStreamConfig {
-    @Autowired
-    private ConsumerGalaxyJsonNftPublishAndBuyReceiver jsonNftPublishAndBuyReceiver;
-
-    @Autowired
-    StringRedisTemplate stringRedisTemplate;
-
-    @Bean
-    public List<Subscription> subscriptionJsonNftPublishAndBuy(RedisConnectionFactory factory) {
-        List<Subscription> subscriptionList = new ArrayList<>();
-        MQConst.GalaxyQueue stream = MQConst.GalaxyQueue.JSON_NFT_PUBLISH_AND_BUY;
-
-        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
-        for (int i = 0; i < 20; 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()), jsonNftPublishAndBuyReceiver
-            ));
-            listenerContainer.start();
-        }
-        return subscriptionList;
-    }
-}
+//package com.liquidnet.service.consumer.nft.config;
+//
+//import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+//import com.liquidnet.service.base.constant.MQConst;
+//import com.liquidnet.service.consumer.nft.receiver.ConsumerGalaxyJsonNftPublishAndBuyReceiver;
+//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;
+//
+///**
+// * @author AnJiabin <anjiabin@zhengzai.tv>
+// * @version V1.0
+// * @Description: 区块链nft订单相关
+// * @class: ConsumerSqlNftOrderInfoConfig
+// * @Package com.liquidnet.service.consumer.galaxy.config
+// * @Copyright: LightNet @ Copyright (c) 2022
+// * @date 2022/3/25 14:45
+// */
+//@Configuration
+//public class ConsumerGalaxyJsonNftPublishAndBuyConfig extends RedisStreamConfig {
+//    @Autowired
+//    private ConsumerGalaxyJsonNftPublishAndBuyReceiver jsonNftPublishAndBuyReceiver;
+//
+//    @Autowired
+//    StringRedisTemplate stringRedisTemplate;
+//
+//    @Bean
+//    public List<Subscription> subscriptionJsonNftPublishAndBuy(RedisConnectionFactory factory) {
+//        List<Subscription> subscriptionList = new ArrayList<>();
+//        MQConst.GalaxyQueue stream = MQConst.GalaxyQueue.JSON_NFT_PUBLISH_AND_BUY;
+//
+//        this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
+//        for (int i = 0; i < 20; 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()), jsonNftPublishAndBuyReceiver
+//            ));
+//            listenerContainer.start();
+//        }
+//        return subscriptionList;
+//    }
+//}

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-nft/src/main/java/com/liquidnet/service/consumer/nft/config/ConsumerGalaxyJsonNftUserRegisterConfig.java

-package com.liquidnet.service.consumer.nft.config;
-
-import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
-import com.liquidnet.service.base.constant.MQConst;
-import com.liquidnet.service.consumer.nft.receiver.ConsumerGalaxyJsonNftUserRegisterReceiver;
-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;
-
-/**
- * @author AnJiabin <anjiabin@zhengzai.tv>
- * @version V1.0
- * @Description: 区块链nft订单相关
- * @class: ConsumerSqlNftOrderInfoConfig
- * @Package com.liquidnet.service.consumer.galaxy.config
- * @Copyright: LightNet @ Copyright (c) 2022
- * @date 2022/3/25 14:45
- */
-@Configuration
-public class ConsumerGalaxyJsonNftUserRegisterConfig extends RedisStreamConfig {
-    @Autowired
-    private ConsumerGalaxyJsonNftUserRegisterReceiver jsonNftUserRegisterReceiver;
-
-    @Autowired
-    StringRedisTemplate stringRedisTemplate;
-
-    @Bean
-    public List<Subscription> subscriptionJsonNftUserRegister(RedisConnectionFactory factory) {
-        List<Subscription> subscriptionList = new ArrayList<>();
-        MQConst.GalaxyQueue stream = MQConst.GalaxyQueue.JSON_NFT_USER_REGISTER;
-
-        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()), jsonNftUserRegisterReceiver
-            ));
-            listenerContainer.start();
-        }
-        return subscriptionList;
-    }
-}
+//package com.liquidnet.service.consumer.nft.config;
+//
+//import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
+//import com.liquidnet.service.base.constant.MQConst;
+//import com.liquidnet.service.consumer.nft.receiver.ConsumerGalaxyJsonNftUserRegisterReceiver;
+//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;
+//
+///**
+// * @author AnJiabin <anjiabin@zhengzai.tv>
+// * @version V1.0
+// * @Description: 区块链nft订单相关
+// * @class: ConsumerSqlNftOrderInfoConfig
+// * @Package com.liquidnet.service.consumer.galaxy.config
+// * @Copyright: LightNet @ Copyright (c) 2022
+// * @date 2022/3/25 14:45
+// */
+//@Configuration
+//public class ConsumerGalaxyJsonNftUserRegisterConfig extends RedisStreamConfig {
+//    @Autowired
+//    private ConsumerGalaxyJsonNftUserRegisterReceiver jsonNftUserRegisterReceiver;
+//
+//    @Autowired
+//    StringRedisTemplate stringRedisTemplate;
+//
+//    @Bean
+//    public List<Subscription> subscriptionJsonNftUserRegister(RedisConnectionFactory factory) {
+//        List<Subscription> subscriptionList = new ArrayList<>();
+//        MQConst.GalaxyQueue stream = MQConst.GalaxyQueue.JSON_NFT_USER_REGISTER;
+//
+//        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()), jsonNftUserRegisterReceiver
+//            ));
+//            listenerContainer.start();
+//        }
+//        return subscriptionList;
+//    }
+//}