From 10ad2e710d2bd52aac31d5d63a7bb6beae76b6a8 Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Tue, 07 Nov 2023 14:35:32 +0800 Subject: [PATCH] 用户列表增加搜索条件 --- src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java | 34 ++++++++++++++++++++++++++++++++++ 1 files changed, 34 insertions(+), 0 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java b/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java index b09877e..0822743 100644 --- a/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java +++ b/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java @@ -48,4 +48,38 @@ } // === 添加机器人 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 === + } -- Gitblit v1.9.1