提交修改

api-mapper/src/main/java/com/heyu/api/data/config/RabbitConfig.java

@@ -9,6 +9,7 @@ import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
 
 import java.util.HashMap;
 import java.util.Map;
@@ -19,7 +20,7 @@ import java.util.Map;
  * @description mq配置
  * @date 2020-12-25
  */
- //@Configuration
+@Configuration
 @Slf4j
 public class RabbitConfig {
 
@@ -73,7 +74,7 @@ public class RabbitConfig {
 
     // ----------------------------   定义exchange   ---------------------------------
     // 定义广播模式的延时交换机 无需绑定路由
-    //@Bean
+    @Bean
     FanoutExchange delayExchange(@Value("${eb.config.rabbitQueue.delayExchangeName}") String delay_exchange_name) {
         Map<String, Object> args = new HashMap<String, Object>();
         args.put("x-delayed-type", "direct");
@@ -83,7 +84,7 @@ public class RabbitConfig {
     }
 
     // 绑定延时队列与交换机
-    //@Bean
+    @Bean
     public Binding delayPayBind(@Value("${eb.config.rabbitQueue.delayQueue}") String delay_queue_name,
                                 @Value("${eb.config.rabbitQueue.delayExchangeName}") String delay_exchange_name) {
         return BindingBuilder

api-web/api-interface/src/main/java/com/heyu/api/listener/CreateDataQueueSimpleRabbitListener.java

@@ -16,6 +16,7 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.messaging.handler.annotation.Header;
 import org.springframework.messaging.handler.annotation.Payload;
+import org.springframework.stereotype.Component;
 import org.springframework.util.CollectionUtils;
 
 import java.io.IOException;
@@ -23,7 +24,7 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
-//@Component
+@Component
 @Slf4j
 public class CreateDataQueueSimpleRabbitListener {
 

api-web/api-interface/src/main/java/com/heyu/api/listener/DelaySimpleRabbitListener.java

@@ -18,13 +18,14 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.messaging.handler.annotation.Header;
 import org.springframework.messaging.handler.annotation.Payload;
+import org.springframework.stereotype.Component;
 
 import java.io.IOException;
 import java.util.Date;
 import java.util.List;
 import java.util.Map;
 
-//@Component
+@Component
 @Slf4j
 public class DelaySimpleRabbitListener {
 

api-web/api-interface/src/main/java/com/heyu/api/listener/PostCodeQueueSimpleRabbitListener.java

@@ -12,11 +12,12 @@ import org.springframework.amqp.support.AmqpHeaders;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.messaging.handler.annotation.Header;
 import org.springframework.messaging.handler.annotation.Payload;
+import org.springframework.stereotype.Component;
 
 import java.io.IOException;
 
 
-// @Component
+@Component
 @Slf4j
 public class PostCodeQueueSimpleRabbitListener {
 

api-web/api-interface/src/main/java/com/heyu/api/listener/SendDingDingQueueSimpleRabbitListener.java

@@ -20,6 +20,7 @@ import org.springframework.amqp.support.AmqpHeaders;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.messaging.handler.annotation.Header;
 import org.springframework.messaging.handler.annotation.Payload;
+import org.springframework.stereotype.Component;
 import org.springframework.util.CollectionUtils;
 
 import java.io.File;
@@ -31,7 +32,7 @@ import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
-//@Component
+@Component
 @Slf4j
 public class SendDingDingQueueSimpleRabbitListener {
 

api-web/api-interface/src/main/java/com/heyu/api/listener/VVUrlQueueSimpleRabbitListener.java

@@ -13,11 +13,12 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.messaging.handler.annotation.Header;
 import org.springframework.messaging.handler.annotation.Payload;
+import org.springframework.stereotype.Component;
 
 import java.io.IOException;
 import java.util.Date;
 
-//@Component
+@Component
 @Slf4j
 public class VVUrlQueueSimpleRabbitListener {