org.rxjava.common.bus

类 RxBusConfiguration

java.lang.Object

org.rxjava.common.bus.RxBusConfiguration

@Configuration
public class RxBusConfiguration
extends java.lang.Object

作者:

happy 2019-05-02 14:32 消息总线配置

构造器概要

构造器

构造器和说明
RxBusConfiguration()

方法概要

限定符和类型	方法和说明
org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer	busContainer(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory, org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter messageListenerAdapter) 消息监听容器
BusEmitter	busEmitter() 消息发射bean
org.springframework.amqp.core.Queue	delayQueue() delay队列
org.springframework.amqp.core.Binding	fanoutBinding(org.springframework.amqp.core.FanoutExchange fanoutExchange, org.springframework.amqp.core.Queue queue) 绑定交换机和队列
org.springframework.amqp.core.FanoutExchange	fanoutExchange() fanout交换机
org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter	messageListenerAdapter(MessageReceiver messageReceiver) 消息监听适配器
MessageReceiver	messageReceiver() 消息接收bean
org.springframework.amqp.core.Queue	queue() 队列

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

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

构造器详细资料

RxBusConfiguration

public RxBusConfiguration()

方法详细资料

fanoutExchange

@Bean
 @Qualifier(value="fanoutExchange")
public org.springframework.amqp.core.FanoutExchange fanoutExchange()

fanout交换机

queue

@Bean
 @ConditionalOnBean(value=BusReceiver.class)
 @Qualifier(value="queue")
public org.springframework.amqp.core.Queue queue()

队列

delayQueue

@Bean
 @ConditionalOnBean(value=BusReceiver.class)
 @Qualifier(value="delayQueue")
public org.springframework.amqp.core.Queue delayQueue()

delay队列

fanoutBinding

@Bean
 @ConditionalOnBean(value=BusReceiver.class)
 @Qualifier(value="fanoutBinding")
public org.springframework.amqp.core.Binding fanoutBinding(@Qualifier(value="fanoutExchange")
                                                                                                                                                 org.springframework.amqp.core.FanoutExchange fanoutExchange,
                                                                                                                                                 @Qualifier(value="queue")
                                                                                                                                                 org.springframework.amqp.core.Queue queue)

绑定交换机和队列

busEmitter

@Bean
public BusEmitter busEmitter()

消息发射bean

messageReceiver

@Bean
 @ConditionalOnBean(value=BusReceiver.class)
 @Qualifier(value="messageReceiver")
public MessageReceiver messageReceiver()

消息接收bean

messageListenerAdapter

@Bean
 @ConditionalOnBean(value=BusReceiver.class)
 @Qualifier(value="messageListenerAdapter")
public org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter messageListenerAdapter(@Qualifier(value="messageReceiver")
                                                                                                                                                                                                     MessageReceiver messageReceiver)

消息监听适配器

busContainer

@Bean
 @ConditionalOnBean(value=BusReceiver.class)
public org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer busContainer(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory,
                                                                                                                                               @Qualifier(value="messageListenerAdapter")
                                                                                                                                               org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter messageListenerAdapter)

消息监听容器