|
|
@@ -19,7 +19,6 @@ public class RabbitMqConsumer extends MqBaseConsumer { |
|
|
//String queueName = "topic-1"; |
|
|
//String queueName = "topic-1"; |
|
|
private String[] queuenames = null; |
|
|
private String[] queuenames = null; |
|
|
|
|
|
|
|
|
@Lazy |
|
|
|
|
|
@Autowired |
|
|
@Autowired |
|
|
private AmqpAdmin amqpAdmin; |
|
|
private AmqpAdmin amqpAdmin; |
|
|
|
|
|
|
|
|
|