实现百度链转让-消费

liquidnet-bus-common/liquidnet-common-service-base/src/main/java/com/liquidnet/service/base/constant/MQConst.java

@@ -330,7 +330,7 @@ public class MQConst {
         SQL_NFT_ORDER_FAIL_LOG("galaxy:stream:rk.sql.nftOrderFailLog", "group.sql.nftOrderFailLog", "交易发行购买失败记录"),
         JSON_NFT_PUBLISH_AND_BUY("galaxy:stream:rk.json.nftPublishAndBuy", "group.json.nftPublishAndBuy", "NFT发行和购买"),
         JSON_NFT_USER_REGISTER("galaxy:stream:rk.json.userRegister", "group.json.userRegister", "NFT用户注册"),
-        JSON_NFT_USER_NFT_TRANSFER("galaxy:stream:rk.json.nftTransfer", "group.json.nftTransfer", "NFT转让");
+        JSON_NFT_TRANSFER("galaxy:stream:rk.json.nftTransfer", "group.json.nftTransfer", "NFT转让");
         private final String key;
         private final String group;
         private final String desc;

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

@@ -188,7 +188,7 @@ public class ConsumerCommonBizRedisStreamConfig extends RedisStreamConfig {
     @Bean
     public List<Subscription> subscriptionGalaxyJsonNftTransfer(RedisConnectionFactory factory) {
         List<Subscription> subscriptionList = new ArrayList<>();
-        MQConst.GalaxyQueue stream = MQConst.GalaxyQueue.JSON_NFT_USER_NFT_TRANSFER;
+        MQConst.GalaxyQueue stream = MQConst.GalaxyQueue.JSON_NFT_TRANSFER;
 
         this.initStream(stringRedisTemplate, stream.getKey(), stream.getGroup());
         for (int i = 0; i < 10; i++) {

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

@@ -48,12 +48,12 @@ public class ConsumerGalaxyJsonNftTransferReceiver extends AbstractBizRedisRecei
 
     @Override
     protected String getRedisStreamKey() {
-        return MQConst.GalaxyQueue.JSON_NFT_USER_NFT_TRANSFER.getKey();
+        return MQConst.GalaxyQueue.JSON_NFT_TRANSFER.getKey();
     }
 
     @Override
     protected String getRedisStreamGroup() {
-        return MQConst.GalaxyQueue.JSON_NFT_USER_NFT_TRANSFER.getGroup();
+        return MQConst.GalaxyQueue.JSON_NFT_TRANSFER.getGroup();
     }
 
     /**