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