|
@@ -25,7 +25,7 @@ public class AmqpInit implements ApplicationRunner,Ordered{
|
|
|
public void run(ApplicationArguments args) throws Exception {
|
|
public void run(ApplicationArguments args) throws Exception {
|
|
|
// TODO Auto-generated method stub
|
|
// TODO Auto-generated method stub
|
|
|
log.info("Amqp初始化>>>");
|
|
log.info("Amqp初始化>>>");
|
|
|
- //amqpClient1.connection();
|
|
|
|
|
|
|
+ amqpClient1.connection();
|
|
|
amqpClient2.connection();
|
|
amqpClient2.connection();
|
|
|
}
|
|
}
|
|
|
|
|
|