| | |
| | | return BindingBuilder.bind(agentUpQueue()).to(agentUpExchange()).with(QueueEnum.BNB_AGENT_UP.getRoute()); |
| | | } |
| | | // === 代理升级 end === |
| | | |
| | | |
| | | |
| | | // === 消息测试 start === |
| | | @Bean |
| | | public DirectExchange bnbTransferTestExchange() { |
| | | return new DirectExchange(QueueEnum.BNB_TRANSFER_TEST.getExchange()); |
| | | } |
| | | |
| | | @Bean |
| | | public Queue bnbTransferTestQueue() { |
| | | return new Queue(QueueEnum.BNB_TRANSFER_TEST.getQueue()); |
| | | } |
| | | |
| | | @Bean |
| | | public Binding bnbTransferTestBind() { |
| | | return BindingBuilder.bind(bnbTransferTestQueue()).to(bnbTransferTestExchange()).with(QueueEnum.BNB_TRANSFER_TEST.getRoute()); |
| | | } |
| | | // === 消息测试 end === |
| | | } |