迁移NFT-sql消费-注释掉

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

 package com.liquidnet.service.consumer.base.config;
 
 import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
-import com.liquidnet.service.base.constant.MQConst;
 import com.liquidnet.service.consumer.base.receiver.ConsumerCommonSQL0Receiver;
-import com.liquidnet.service.consumer.base.receiver.ConsumerGoblinNftOrderRdsReceiver;
 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;
 
 /**
  * 公共的SQL队列消息消费器初始化配置
@@ -32,8 +19,8 @@ public class ConsumerCommonSqlRedisStreamConfig extends RedisStreamConfig {
     @Autowired
     ConsumerCommonSQL0Receiver consumerCommonSQL0Receiver;
 
-    @Autowired
-    ConsumerGoblinNftOrderRdsReceiver consumerGoblinNftOrderRdsReceiver;
+//    @Autowired
+//    ConsumerGoblinNftOrderRdsReceiver consumerGoblinNftOrderRdsReceiver;
 
 //    @Bean
 //    public List<Subscription> subscriptionSQL0(RedisConnectionFactory factory) {
@@ -51,19 +38,19 @@ 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;
-    }
+//    @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;
+//    }
 }