//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);
//	}
//}