修改galaxy消费相关

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

@@ -2,7 +2,7 @@ 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.ConsumerGalaxySqlSeriesInfoReceiver;
+import com.liquidnet.service.consumer.kylin.receiver.ConsumerGalaxySqlNftOrderInfoReceiver;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -30,7 +30,7 @@ import java.util.List;
 @Configuration
 public class ConsumerGalaxySqlNftOrderInfoConfig extends RedisStreamConfig {
     @Autowired
-    private ConsumerGalaxySqlSeriesInfoReceiver sqlSeriesInfoReceiver;
+    private ConsumerGalaxySqlNftOrderInfoReceiver sqlNftOrderInfoReceiver;
 
     @Autowired
     StringRedisTemplate stringRedisTemplate;
@@ -45,7 +45,7 @@ public class ConsumerGalaxySqlNftOrderInfoConfig 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()), sqlSeriesInfoReceiver
+                    StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), sqlNftOrderInfoReceiver
             ));
             listenerContainer.start();
         }

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

@@ -2,7 +2,7 @@ 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.ConsumerGalaxySqlNftOrderInfoReceiver;
+import com.liquidnet.service.consumer.kylin.receiver.ConsumerGalaxySqlNftTradeInfoReceiver;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
@@ -30,7 +30,7 @@ import java.util.List;
 @Configuration
 public class ConsumerGalaxySqlNftTradeInfoConfig extends RedisStreamConfig {
     @Autowired
-    private ConsumerGalaxySqlNftOrderInfoReceiver sqlNftOrderInfoReceiver;
+    private ConsumerGalaxySqlNftTradeInfoReceiver sqlNftTradeInfoReceiver;
 
     @Autowired
     StringRedisTemplate stringRedisTemplate;
@@ -45,7 +45,7 @@ public class ConsumerGalaxySqlNftTradeInfoConfig 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()), sqlNftOrderInfoReceiver
+                    StreamOffset.create(stream.getKey(), ReadOffset.lastConsumed()), sqlNftTradeInfoReceiver
             ));
             listenerContainer.start();
         }