From c1af5cf94920702b6aa962881365116542e88ab0 Mon Sep 17 00:00:00 2001 From: KKSU <15274802129@163.com> Date: Tue, 30 Jul 2024 09:42:46 +0800 Subject: [PATCH] 后台 --- src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java | 41 +++++++++++++++++++++++++++++++++++++++++ 1 files changed, 41 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 cdca235..1e7d307 100644 --- a/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java +++ b/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java @@ -81,5 +81,46 @@ return BindingBuilder.bind(orderDelayQueueTtl()).to(delayTtlExchange()).with(RabbitQueueEnum.ORDER_CANCEL_DELAY_TTL.getRoute()); } + @Bean + public Queue autoLevelUpAgentQueue() { + return new Queue(QueueConstants.AGENT_AUTO_LEVEL_UP); + } + + @Bean + public Binding autoLevelUpBind() { + return BindingBuilder.bind(autoLevelUpAgentQueue()).to(defaultExchange()).with(RouteKeyConstants.ROUTE_KEY_DEFAULT); + } + // 订单返利 开始 + @Bean + public DirectExchange agentReturnMoneyExchange() { + return new DirectExchange(RabbitQueueEnum.AGENT_RETURN_MONEY.getExchange()); + } + + @Bean + public Queue agentReturnMoneyQueue() { + return new Queue(QueueConstants.AGENT_RETURN_MONEY); + } + + @Bean + public Binding agentReturnMoneyBind() { + return BindingBuilder.bind(agentReturnMoneyQueue()).to(agentReturnMoneyExchange()).with(RabbitQueueEnum.AGENT_RETURN_MONEY.getRoute()); + } + // 订单返利 结束 + + + @Bean + public DirectExchange orderReturnMoneyExchange() { + return new DirectExchange(RabbitQueueEnum.ORDER_RETURN_MONEY.getExchange()); + } + + @Bean + public Queue orderReturnMoneyQueue() { + return new Queue(QueueConstants.ORDER_RETURN_MONEY); + } + + @Bean + public Binding orderReturnMoneyBind() { + return BindingBuilder.bind(orderReturnMoneyQueue()).to(orderReturnMoneyExchange()).with(RabbitQueueEnum.ORDER_RETURN_MONEY.getRoute()); + } } -- Gitblit v1.9.1