From 27f8fa9cba4bcf96c82dba9a48d6dc2855d0ea9c Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Thu, 16 Jun 2022 18:24:07 +0800 Subject: [PATCH] fix --- src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java | 16 ++++++++++++++++ 1 files changed, 16 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 e07ba36..50797b6 100644 --- a/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java +++ b/src/main/java/cc/mrbird/febs/common/configure/RabbitConfigure.java @@ -106,4 +106,20 @@ return BindingBuilder.bind(agentReturnMoneyQueue()).to(agentReturnMoneyExchange()).with(RabbitQueueEnum.AGENT_REUTRN_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