From 848e08c6cef8a6d62c9c9aa40b2f0b9363f3137f Mon Sep 17 00:00:00 2001 From: xiaoyong931011 <15274802129@163.com> Date: Mon, 27 Sep 2021 16:03:23 +0800 Subject: [PATCH] Merge branch 'master' of http://120.27.238.55:7000/r/xc-mall --- src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java | 15 +++++++++++++++ 1 files changed, 15 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 b44e323..e07ba36 100644 --- a/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java +++ b/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java @@ -91,4 +91,19 @@ return BindingBuilder.bind(autoLevelUpAgentQueue()).to(defaultExchange()).with(RouteKeyConstants.ROUTE_KEY_DEFAULT); } + @Bean + public DirectExchange agentReturnMoneyExchange() { + return new DirectExchange(RabbitQueueEnum.AGENT_REUTRN_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_REUTRN_MONEY.getRoute()); + } + } -- Gitblit v1.9.1