| | |
| | | return BindingBuilder.bind(bnbTransferQueue()).to(bnbTransferExchange()).with(QueueEnum.BNB_TRANSFER.getRoute()); |
| | | } |
| | | // === 转账拨币 end === |
| | | |
| | | |
| | | |
| | | // === 代理升级 start === |
| | | @Bean |
| | | public DirectExchange agentUpExchange() { |
| | | return new DirectExchange(QueueEnum.BNB_AGENT_UP.getExchange()); |
| | | } |
| | | |
| | | @Bean |
| | | public Queue agentUpQueue() { |
| | | return new Queue(QueueEnum.BNB_AGENT_UP.getQueue()); |
| | | } |
| | | |
| | | @Bean |
| | | public Binding agentUpBind() { |
| | | 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 === |
| | | } |