修改nft用户注册

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

-package com.liquidnet.service.consumer.kylin.config;
-
-import com.liquidnet.common.cache.redis.config.RedisStreamConfig;
-import com.liquidnet.service.base.constant.MQConst;
-import com.liquidnet.service.consumer.kylin.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;
-    }
-}