xin.alum.aim.rabbitmq

类 RabbitMQConfig

java.lang.Object

xin.alum.aim.rabbitmq.RabbitMQConfig

@Configuration
 @ConditionalOnProperty(prefix="alum.aim.cluster",
                       name="mode",
                       havingValue="rabbitmq")
public class RabbitMQConfig
extends Object

作者:

alum

字段概要

字段

限定符和类型	字段和说明
protected io.netty.util.internal.logging.InternalLogger	logger

构造器概要

构造器

构造器和说明
RabbitMQConfig()

方法概要

限定符和类型	方法和说明
org.springframework.amqp.core.Binding	bindKick()
org.springframework.amqp.core.Binding	bindMessage()
org.springframework.amqp.core.Binding	bindReply()
org.springframework.amqp.core.FanoutExchange	fanoutExchange() 针对消费者配置: 1.
org.springframework.amqp.core.Queue	kick()
org.springframework.amqp.core.Queue	message()
org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer	messageListenerContainer(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
RabbitMessageListener	rabbitMessageListener()
RabbitMQPusher	rabbitMQPusher()
org.springframework.amqp.rabbit.core.RabbitTemplate	rabbitTemplate(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
org.springframework.amqp.core.Queue	reply()

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

logger

protected final io.netty.util.internal.logging.InternalLogger logger

构造器详细资料

RabbitMQConfig

public RabbitMQConfig()

方法详细资料

fanoutExchange

@Bean
public org.springframework.amqp.core.FanoutExchange fanoutExchange()

针对消费者配置:

1. 设置交换机类型。

2. 将队列绑定到交换机。

FanoutExchange: 将消息分发到所有的绑定队列，无routingkey的概念。

HeadersExchange ：通过添加属性key-value匹配。

DirectExchange:按照routingkey分发到指定队列。

TopicExchange:多关键字匹配。

reply

@Bean
public org.springframework.amqp.core.Queue reply()

message

@Bean
public org.springframework.amqp.core.Queue message()

kick

@Bean
public org.springframework.amqp.core.Queue kick()

bindReply

@Bean
public org.springframework.amqp.core.Binding bindReply()

bindMessage

@Bean
public org.springframework.amqp.core.Binding bindMessage()

bindKick

@Bean
public org.springframework.amqp.core.Binding bindKick()

rabbitMessageListener

@Bean
public RabbitMessageListener rabbitMessageListener()

rabbitTemplate

public org.springframework.amqp.rabbit.core.RabbitTemplate rabbitTemplate(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)

messageListenerContainer

@Bean
public org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer messageListenerContainer(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)

参数:

connectionFactory -

返回:

rabbitMQPusher

@Bean
public RabbitMQPusher rabbitMQPusher()