diff --git a/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java b/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java index d2ade2f6f..16f9c5fb5 100644 --- a/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java +++ b/mallinkMQConsumer/src/main/java/com/iformall/mq/MqBaseConsumer.java @@ -57,7 +57,6 @@ public class MqBaseConsumer { @Autowired private FmInsideCLoginMsgServiceImpl fmInsideCLoginMsgService; - @Lazy @Autowired private MqBaseProducer mqBaseProducer; diff --git a/mallinkMQConsumer/src/main/java/com/iformall/mq/impl/RabbitMqConsumer.java b/mallinkMQConsumer/src/main/java/com/iformall/mq/impl/RabbitMqConsumer.java index 1bb451612..b67d8a39a 100644 --- a/mallinkMQConsumer/src/main/java/com/iformall/mq/impl/RabbitMqConsumer.java +++ b/mallinkMQConsumer/src/main/java/com/iformall/mq/impl/RabbitMqConsumer.java @@ -19,7 +19,6 @@ public class RabbitMqConsumer extends MqBaseConsumer { //String queueName = "topic-1"; private String[] queuenames = null; - @Lazy @Autowired private AmqpAdmin amqpAdmin;