public class RabbitMessageBus extends MessageBusSupport implements org.springframework.beans.factory.DisposableBean
MessageBus implementation backed by RabbitMQ.ORIGINAL_CONTENT_TYPE_HEADER, XD_JSON_OCTET_STREAM_VALUE, XD_OCTET_STREAM_VALUE, XD_TEXT_PLAIN_UTF8_VALUE| Constructor and Description |
|---|
RabbitMessageBus(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory) |
| Modifier and Type | Method and Description |
|---|---|
void |
bindConsumer(java.lang.String name,
org.springframework.integration.MessageChannel moduleInputChannel,
java.util.Collection<org.springframework.http.MediaType> acceptedMediaTypes,
boolean aliasHint)
Bind a message consumer on a p2p channel
|
void |
bindProducer(java.lang.String name,
org.springframework.integration.MessageChannel moduleOutputChannel,
boolean aliasHint)
Bind a message producer on a p2p channel.
|
void |
bindPubSubConsumer(java.lang.String name,
org.springframework.integration.MessageChannel moduleInputChannel,
java.util.Collection<org.springframework.http.MediaType> acceptedMediaTypes)
Bind a message consumer on a pub/sub channel
|
void |
bindPubSubProducer(java.lang.String name,
org.springframework.integration.MessageChannel moduleOutputChannel)
Bind a message producer on a pub/sub channel.
|
void |
destroy() |
addBridge, deleteBridge, deleteBridges, setBeanClassLoader, setConversionService, stopBridges, transformInboundIfNecessary, transformOutboundIfNecessary, unbindConsumer, unbindConsumers, unbindProducer, unbindProducerspublic RabbitMessageBus(org.springframework.amqp.rabbit.connection.ConnectionFactory connectionFactory)
public void bindConsumer(java.lang.String name,
org.springframework.integration.MessageChannel moduleInputChannel,
java.util.Collection<org.springframework.http.MediaType> acceptedMediaTypes,
boolean aliasHint)
MessageBusbindConsumer in interface MessageBusname - the logical identity of the message sourcemoduleInputChannel - the channel bound as a consumeracceptedMediaTypes - the media types supported by the channelaliasHint - whether the provided name represents an alias and thus should support late bindingpublic void bindPubSubConsumer(java.lang.String name,
org.springframework.integration.MessageChannel moduleInputChannel,
java.util.Collection<org.springframework.http.MediaType> acceptedMediaTypes)
MessageBusbindPubSubConsumer in interface MessageBusname - the logical identity of the message sourceacceptedMediaTypes - the media types supported by the channelpublic void bindProducer(java.lang.String name,
org.springframework.integration.MessageChannel moduleOutputChannel,
boolean aliasHint)
MessageBusbindProducer in interface MessageBusname - the logical identity of the message targetmoduleOutputChannel - the channel bound as a produceraliasHint - whether the provided name represents an alias and thus should support late bindingpublic void bindPubSubProducer(java.lang.String name,
org.springframework.integration.MessageChannel moduleOutputChannel)
MessageBusbindPubSubProducer in interface MessageBusname - the logical identity of the message targetpublic void destroy()
destroy in interface org.springframework.beans.factory.DisposableBean