public interface MessageBus
MessageChannel
to a logical name. The name is intended to identify a
logical consumer or producer of messages. This may be a queue, a channel adapter, another message channel, a Spring
bean, etc.Modifier and Type | Method and Description |
---|---|
void |
bindConsumer(java.lang.String name,
org.springframework.messaging.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.messaging.MessageChannel moduleOutputChannel,
boolean aliasHint)
Bind a message producer on a p2p channel.
|
void |
bindPubSubConsumer(java.lang.String name,
org.springframework.messaging.MessageChannel inputChannel,
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.messaging.MessageChannel outputChannel)
Bind a message producer on a pub/sub channel.
|
void |
unbindConsumer(java.lang.String name,
org.springframework.messaging.MessageChannel channel)
Unbind a specific p2p or pub/sub message consumer
|
void |
unbindConsumers(java.lang.String name)
Unbind an inbound inter-module channel and stop any active components that use the channel.
|
void |
unbindProducer(java.lang.String name,
org.springframework.messaging.MessageChannel channel)
Unbind a specific p2p or pub/sub message producer
|
void |
unbindProducers(java.lang.String name)
Unbind an outbound inter-module channel and stop any active components that use the channel.
|
void bindConsumer(java.lang.String name, org.springframework.messaging.MessageChannel moduleInputChannel, java.util.Collection<org.springframework.http.MediaType> acceptedMediaTypes, boolean aliasHint)
name
- 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 bindingvoid bindPubSubConsumer(java.lang.String name, org.springframework.messaging.MessageChannel inputChannel, java.util.Collection<org.springframework.http.MediaType> acceptedMediaTypes)
name
- the logical identity of the message sourceinputChannel
- the channel bound as a pub/sub consumeracceptedMediaTypes
- the media types supported by the channelvoid bindProducer(java.lang.String name, org.springframework.messaging.MessageChannel moduleOutputChannel, boolean aliasHint)
name
- 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 bindingvoid bindPubSubProducer(java.lang.String name, org.springframework.messaging.MessageChannel outputChannel)
name
- the logical identity of the message targetoutputChannel
- the channel bound as a producervoid unbindConsumers(java.lang.String name)
name
- the channel namevoid unbindProducers(java.lang.String name)
name
- the channel namevoid unbindConsumer(java.lang.String name, org.springframework.messaging.MessageChannel channel)
name
- The logical identify of a message sourcechannel
- The channel bound as a consumervoid unbindProducer(java.lang.String name, org.springframework.messaging.MessageChannel channel)
name
- the logical identity of the message targetchannel
- the channel bound as a producer