From 38d775fa2ccd433c727a5b7cec8bed02493df1ec Mon Sep 17 00:00:00 2001
From: zhongrj <123456>
Date: Thu, 18 Aug 2022 09:00:40 +0800
Subject: [PATCH] mq 相关配置去除，启动配置修改
---
src/main/java/org/springblade/modules/rabbitmq/config/MQConfig.java | 128 +++++++++++++++++++++---------------------
1 files changed, 64 insertions(+), 64 deletions(-)
diff --git a/src/main/java/org/springblade/modules/rabbitmq/config/MQConfig.java b/src/main/java/org/springblade/modules/rabbitmq/config/MQConfig.java
index 789d961..05f1996 100644
--- a/src/main/java/org/springblade/modules/rabbitmq/config/MQConfig.java
+++ b/src/main/java/org/springblade/modules/rabbitmq/config/MQConfig.java
@@ -1,64 +1,64 @@
-package org.springblade.modules.rabbitmq.config;
-
-import org.springframework.amqp.core.*;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-
-/**
- * rabbitmq 配置文件
- * @author zhongrj
- * @since 2022-04-08
- */
-@Configuration
-public class MQConfig {
- public static final String QUEUE = "queue";
- public static final String TOPIC_QUEUE1= "topic.queue1";
- public static final String TOPIC_QUEUE2 = "topic.queue2";
- public static final String TOPIC_EXCHANGE = "topicExchange";
- public static final String FANOUT_EXCHANGE = "fanoutxchage";
- public static final String TASK_QUEUE = "task_queue";
-
- @Bean
- public Queue taskQueue(){
- return new Queue(TASK_QUEUE,true);
- }
-
- //Direct模式
- @Bean
- public Queue queue(){
- return new Queue(QUEUE,true);
- }
-
- //topic交换机模式
- @Bean
- public Queue topicQueue1(){
- return new Queue(TOPIC_QUEUE1,true);
- }
-
- @Bean
- public Queue topicQueue2(){
- return new Queue(TOPIC_QUEUE2,true);
- }
-
- @Bean
- public TopicExchange topicExchange(){
- return new TopicExchange(TOPIC_EXCHANGE);
- }
-
- @Bean
- public Binding topicBinding1(){
- return BindingBuilder.bind(topicQueue1()).to(topicExchange()).with("topic.key1");
- }
-
- @Bean
- public Binding topicBinding2(){
- return BindingBuilder.bind(topicQueue2()).to(topicExchange()).with("topic.#");
- }
-
- //Fanout模式，广播模式
-
- @Bean
- public FanoutExchange fanoutExchange(){
- return new FanoutExchange(FANOUT_EXCHANGE);
- }
-}
+//package org.springblade.modules.rabbitmq.config;
+//
+//import org.springframework.amqp.core.*;
+//import org.springframework.context.annotation.Bean;
+//import org.springframework.context.annotation.Configuration;
+//
+///**
+// * rabbitmq 配置文件
+// * @author zhongrj
+// * @since 2022-04-08
+// */
+//@Configuration
+//public class MQConfig {
+// public static final String QUEUE = "queue";
+// public static final String TOPIC_QUEUE1= "topic.queue1";
+// public static final String TOPIC_QUEUE2 = "topic.queue2";
+// public static final String TOPIC_EXCHANGE = "topicExchange";
+// public static final String FANOUT_EXCHANGE = "fanoutxchage";
+// public static final String TASK_QUEUE = "task_queue";
+//
+// @Bean
+// public Queue taskQueue(){
+// return new Queue(TASK_QUEUE,true);
+// }
+//
+// //Direct模式
+// @Bean
+// public Queue queue(){
+// return new Queue(QUEUE,true);
+// }
+//
+// //topic交换机模式
+// @Bean
+// public Queue topicQueue1(){
+// return new Queue(TOPIC_QUEUE1,true);
+// }
+//
+// @Bean
+// public Queue topicQueue2(){
+// return new Queue(TOPIC_QUEUE2,true);
+// }
+//
+// @Bean
+// public TopicExchange topicExchange(){
+// return new TopicExchange(TOPIC_EXCHANGE);
+// }
+//
+// @Bean
+// public Binding topicBinding1(){
+// return BindingBuilder.bind(topicQueue1()).to(topicExchange()).with("topic.key1");
+// }
+//
+// @Bean
+// public Binding topicBinding2(){
+// return BindingBuilder.bind(topicQueue2()).to(topicExchange()).with("topic.#");
+// }
+//
+// //Fanout模式，广播模式
+//
+// @Bean
+// public FanoutExchange fanoutExchange(){
+// return new FanoutExchange(FANOUT_EXCHANGE);
+// }
+//}
--
Gitblit v1.9.3