From f3b3b6ccbac014388727f91411ae5e926d9fee02 Mon Sep 17 00:00:00 2001 From: Derran Date: Mon, 29 Apr 2024 19:35:28 +0800 Subject: [PATCH] =?UTF-8?q?=E5=9F=BA=E7=A1=80=E9=85=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../infrastructure/config/RabbitmqConfig.java | 18 ------------------ 1 file changed, 18 deletions(-) diff --git a/dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/config/RabbitmqConfig.java b/dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/config/RabbitmqConfig.java index b6fed3e..2561833 100644 --- a/dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/config/RabbitmqConfig.java +++ b/dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/config/RabbitmqConfig.java @@ -1,27 +1,9 @@ package com.qniao.dam.infrastructure.config; -import com.qniao.ppf.infrastructure.constant.MqQueue; -import com.qniao.ppf.infrastructure.constant.PrintingPackagingFactoryMqExchange; -import org.springframework.amqp.core.Binding; -import org.springframework.amqp.core.BindingBuilder; -import org.springframework.amqp.core.FanoutExchange; -import org.springframework.amqp.core.Queue; -import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @Configuration public class RabbitmqConfig { - @Bean - Binding paymentOrderPaidBinding() { - return BindingBuilder.bind(new Queue(MqQueue.PAYMENT_ORDER_PAID)) - .to(new FanoutExchange(PrintingPackagingFactoryMqExchange.PAYMENT_ORDER_PAID)); - } - - @Bean - Binding walletPaymentOrderPaidBinding() { - return BindingBuilder.bind(new Queue(MqQueue.WALLET_PAYMENT_ORDER_PAID)) - .to(new FanoutExchange(PrintingPackagingFactoryMqExchange.WALLET_PAYMENT_ORDER_PAID)); - } }