src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java
@@ -77,4 +77,23 @@ } // end // start @Bean public DirectExchange nodeUpExchange() { return new DirectExchange(RabbitQueueEnum.RUN_VIP_NODE_UP.getExchange()); } @Bean public Queue nodeUpQueue() { return new Queue(RabbitQueueEnum.RUN_VIP_NODE_UP.getQueue()); } @Bean public Binding nodeUpBind() { return BindingBuilder.bind(nodeUpQueue()).to(nodeUpExchange()).with(RabbitQueueEnum.RUN_VIP_NODE_UP.getRoute()); } // end }