fix:包目录调整;

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-adam/src/main/java/com/liquidnet/service/consumer/adam/config/ConsumerAdamSqlUcenterRedisStreamConfig.java

 package com.liquidnet.service.consumer.adam.config;
 
-import com.liquidnet.service.consumer.adam.receiver.ConsumerAdamUCenterRdsReceiverSql;
-import com.liquidnet.service.consumer.adam.receiver.ConsumerAdamUMemberRdsReceiverSql;
-import com.liquidnet.service.consumer.adam.receiver.ConsumerAdamURegisterRdsReceiverSql;
+import com.liquidnet.service.consumer.adam.receiver.ConsumerAdamSqlUCenterRdsReceiver;
+import com.liquidnet.service.consumer.adam.receiver.ConsumerAdamSqlUMemberRdsReceiver;
+import com.liquidnet.service.consumer.adam.receiver.ConsumerAdamSqlURegisterRdsReceiver;
 import lombok.var;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Bean;
@@ -22,11 +22,11 @@ import static com.liquidnet.service.base.constant.MQConst.*;
 @Configuration
 public class ConsumerAdamSqlUcenterRedisStreamConfig {
     @Autowired
-    ConsumerAdamURegisterRdsReceiverSql consumerAdamURegisterRdsReceiver;
+    ConsumerAdamSqlURegisterRdsReceiver consumerAdamURegisterRdsReceiver;
     @Autowired
-    ConsumerAdamUCenterRdsReceiverSql consumerAdamUCenterRdsReceiver;
+    ConsumerAdamSqlUCenterRdsReceiver consumerAdamUCenterRdsReceiver;
     @Autowired
-    ConsumerAdamUMemberRdsReceiverSql consumerAdamUMemberRdsReceiver;
+    ConsumerAdamSqlUMemberRdsReceiver consumerAdamUMemberRdsReceiver;
 
     private StreamMessageListenerContainer<String, MapRecord<String, String, String>> buildStreamMessageListenerContainer(RedisConnectionFactory factory) {
         var options = StreamMessageListenerContainer

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-adam/src/main/java/com/liquidnet/service/consumer/adam/receiver/ConsumerAdamUCenterRdsReceiverSql.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-adam/src/main/java/com/liquidnet/service/consumer/adam/receiver/ConsumerAdamSqlUCenterRdsReceiver.java

@@ -6,7 +6,7 @@ import org.springframework.stereotype.Component;
 
 @Slf4j
 @Component
-public class ConsumerAdamUCenterRdsReceiverSql extends AbstractSqlRedisReceiver {
+public class ConsumerAdamSqlUCenterRdsReceiver extends AbstractSqlRedisReceiver {
     @Override
     protected String getRedisStreamKey() {
         return MQConst.AdamQueue.SQL_UCENTER.getKey();

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-adam/src/main/java/com/liquidnet/service/consumer/adam/receiver/ConsumerAdamUMemberRdsReceiverSql.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-adam/src/main/java/com/liquidnet/service/consumer/adam/receiver/ConsumerAdamSqlUMemberRdsReceiver.java

@@ -6,7 +6,7 @@ import org.springframework.stereotype.Component;
 
 @Slf4j
 @Component
-public class ConsumerAdamUMemberRdsReceiverSql extends AbstractSqlRedisReceiver {
+public class ConsumerAdamSqlUMemberRdsReceiver extends AbstractSqlRedisReceiver {
     @Override
     protected String getRedisStreamKey() {
         return MQConst.AdamQueue.SQL_UMEMBER.getKey();

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-adam/src/main/java/com/liquidnet/service/consumer/adam/receiver/ConsumerAdamURegisterRdsReceiverSql.java → liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-adam/src/main/java/com/liquidnet/service/consumer/adam/receiver/ConsumerAdamSqlURegisterRdsReceiver.java

@@ -6,7 +6,7 @@ import org.springframework.stereotype.Component;
 
 @Slf4j
 @Component
-public class ConsumerAdamURegisterRdsReceiverSql extends AbstractSqlRedisReceiver {
+public class ConsumerAdamSqlURegisterRdsReceiver extends AbstractSqlRedisReceiver {
     @Override
     protected String getRedisStreamKey() {
         return MQConst.AdamQueue.SQL_UREGISTER.getKey();