diff --git a/api-mapper/src/main/java/com/heyu/api/data/config/RabbitConfig.java b/api-mapper/src/main/java/com/heyu/api/data/config/RabbitConfig.java index 47c10b2..ed6bda6 100644 --- a/api-mapper/src/main/java/com/heyu/api/data/config/RabbitConfig.java +++ b/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 args = new HashMap(); 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 diff --git a/api-web/api-interface/src/main/java/com/heyu/api/listener/CreateDataQueueSimpleRabbitListener.java b/api-web/api-interface/src/main/java/com/heyu/api/listener/CreateDataQueueSimpleRabbitListener.java index 4ad34d6..618d284 100644 --- a/api-web/api-interface/src/main/java/com/heyu/api/listener/CreateDataQueueSimpleRabbitListener.java +++ b/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 { diff --git a/api-web/api-interface/src/main/java/com/heyu/api/listener/DelaySimpleRabbitListener.java b/api-web/api-interface/src/main/java/com/heyu/api/listener/DelaySimpleRabbitListener.java index e2f8c21..785011f 100644 --- a/api-web/api-interface/src/main/java/com/heyu/api/listener/DelaySimpleRabbitListener.java +++ b/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 { diff --git a/api-web/api-interface/src/main/java/com/heyu/api/listener/PostCodeQueueSimpleRabbitListener.java b/api-web/api-interface/src/main/java/com/heyu/api/listener/PostCodeQueueSimpleRabbitListener.java index 8236ab0..6a235a7 100644 --- a/api-web/api-interface/src/main/java/com/heyu/api/listener/PostCodeQueueSimpleRabbitListener.java +++ b/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 { diff --git a/api-web/api-interface/src/main/java/com/heyu/api/listener/SendDingDingQueueSimpleRabbitListener.java b/api-web/api-interface/src/main/java/com/heyu/api/listener/SendDingDingQueueSimpleRabbitListener.java index ea72540..84d0b33 100644 --- a/api-web/api-interface/src/main/java/com/heyu/api/listener/SendDingDingQueueSimpleRabbitListener.java +++ b/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 { diff --git a/api-web/api-interface/src/main/java/com/heyu/api/listener/VVUrlQueueSimpleRabbitListener.java b/api-web/api-interface/src/main/java/com/heyu/api/listener/VVUrlQueueSimpleRabbitListener.java index 4e8065f..ab25c12 100644 --- a/api-web/api-interface/src/main/java/com/heyu/api/listener/VVUrlQueueSimpleRabbitListener.java +++ b/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 {