| | |
| | | } |
| | | // === 添加机器人 end === |
| | | |
| | | // === 自动发送 start === |
| | | @Bean |
| | | public DirectExchange imAutoSendExchange() { |
| | | return new DirectExchange(RabbitQueueEnum.IM_REDBAG_AUTO_SEND.getExchange()); |
| | | } |
| | | |
| | | @Bean |
| | | public Queue imAutoSendQueue() { |
| | | return new Queue(RabbitQueueEnum.IM_REDBAG_AUTO_SEND.getQueue()); |
| | | } |
| | | |
| | | @Bean |
| | | public Binding imAutoSendBind() { |
| | | return BindingBuilder.bind(imAutoSendQueue()).to(imAutoSendExchange()).with(RabbitQueueEnum.IM_REDBAG_AUTO_SEND.getRoute()); |
| | | } |
| | | // === 自动发送 end === |
| | | |
| | | // === 自动发送 start === |
| | | @Bean |
| | | public DirectExchange imOverdueSendExchange() { |
| | | return new DirectExchange(RabbitQueueEnum.IM_REDBAG_OVERDUE.getExchange()); |
| | | } |
| | | |
| | | @Bean |
| | | public Queue imOverdueSendQueue() { |
| | | return new Queue(RabbitQueueEnum.IM_REDBAG_OVERDUE.getQueue()); |
| | | } |
| | | |
| | | @Bean |
| | | public Binding imOverdueSendBind() { |
| | | return BindingBuilder.bind(imOverdueSendQueue()).to(imOverdueSendExchange()).with(RabbitQueueEnum.IM_REDBAG_OVERDUE.getRoute()); |
| | | } |
| | | // === 自动发送 end === |
| | | |
| | | } |