批量空投

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

@@ -14,7 +14,6 @@ import java.util.Arrays;
 
 @Slf4j
 @SpringBootApplication(scanBasePackages = {"com.liquidnet"})
-@MapperScan(basePackages = "com.liquidnet.service.*.mapper")
 public class ServiceConsumerKylinApplication implements CommandLineRunner {
     @Autowired
     private Environment environment;
@@ -42,3 +41,4 @@ public class ServiceConsumerKylinApplication implements CommandLineRunner {
         }
     }
 }
+

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

@@ -15,8 +15,9 @@ import org.springframework.data.redis.connection.stream.StreamOffset;
 import org.springframework.data.redis.stream.StreamMessageListenerContainer;
 import org.springframework.data.redis.stream.Subscription;
 
-@Configuration
+// @Configuration
 public class ConsumerGoblinCodeStreamConfig  extends RedisStreamConfig {
+/*
     @Autowired
     ConsumerGoblinCodeReceiver consumerGoblinCodeReceiver;
 
@@ -33,6 +34,7 @@ public class ConsumerGoblinCodeStreamConfig  extends RedisStreamConfig {
         listenerContainer.start();
         return subscription;
     }
+*/
 
 
 

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

@@ -17,9 +17,10 @@ import org.springframework.data.redis.stream.Subscription;
 import com.liquidnet.service.consumer.kylin.receiver.ConsumerGoblinPhoneCodeReceiver;
 
 
-@Configuration
+// @Configuration
 public class ConsumerGoblinPhoneCodeStreamConfig extends RedisStreamConfig {
 
+/*
     @Autowired
     ConsumerGoblinPhoneCodeReceiver consumerGoblinPhoneCodeReceiver;
 
@@ -36,6 +37,7 @@ public class ConsumerGoblinPhoneCodeStreamConfig extends RedisStreamConfig {
         listenerContainer.start();
         return subscription;
     }
+*/
 
 
 /*    @Bean

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerGoblinCodeReceiver.java

@@ -5,7 +5,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Component;
 
 @Slf4j
-@Component
+// @Component
 public class ConsumerGoblinCodeReceiver extends AbstractSqlRedisReceiver{
     @Override
     protected String getRedisStreamKey() {

liquidnet-bus-service/liquidnet-service-consumer-all/liquidnet-service-consumer-kylin/src/main/java/com/liquidnet/service/consumer/kylin/receiver/ConsumerGoblinPhoneCodeReceiver.java

@@ -20,7 +20,7 @@ import java.util.List;
 import java.util.Map;
 
 @Slf4j
-@Component
+// @Component
 public class ConsumerGoblinPhoneCodeReceiver extends AbstractHttpRedisReceiver{
 
     @Override