| | |
| | | } |
| | | // 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 |
| | | |
| | | |
| | | |
| | | // start |
| | | @Bean |
| | | public DirectExchange chargeExchange() { |
| | | return new DirectExchange(RabbitQueueEnum.RUN_VIP_OPERATION_CHARGE_BALANCE.getExchange()); |
| | | } |
| | | |
| | | @Bean |
| | | public Queue chargeQueue() { |
| | | return new Queue(RabbitQueueEnum.RUN_VIP_OPERATION_CHARGE_BALANCE.getQueue()); |
| | | } |
| | | |
| | | @Bean |
| | | public Binding chargeBind() { |
| | | return BindingBuilder.bind(chargeQueue()).to(chargeExchange()).with(RabbitQueueEnum.RUN_VIP_OPERATION_CHARGE_BALANCE.getRoute()); |
| | | } |
| | | // end |
| | | |
| | | } |