| | |
| | | return BindingBuilder.bind(nodeAgainQueue()).to(nodeAgainExchange()).with(QueueEnum.TFC_NODE_AGAIN.getRoute()); |
| | | } |
| | | // === 发送复投 end === |
| | | |
| | | |
| | | |
| | | |
| | | |
| | | // === 发送复投 start === |
| | | @Bean |
| | | public DirectExchange nodeAgainExchangeLong() { |
| | | return new DirectExchange(QueueEnum.TFC_NODE_AGAIN_LONG.getExchange()); |
| | | } |
| | | |
| | | @Bean |
| | | public Queue nodeAgainQueueLong() { |
| | | return new Queue(QueueEnum.TFC_NODE_AGAIN_LONG.getQueue()); |
| | | } |
| | | |
| | | @Bean |
| | | public Binding nodeAgainBindLong() { |
| | | return BindingBuilder.bind(nodeAgainQueueLong()).to(nodeAgainExchangeLong()).with(QueueEnum.TFC_NODE_AGAIN_LONG.getRoute()); |
| | | } |
| | | // === 发送复投 end === |
| | | } |