org.springframework.integration.x.bus

Class LocalMessageBus

java.lang.Object

org.springframework.integration.x.bus.MessageBusSupport

org.springframework.integration.x.bus.LocalMessageBus

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, MessageBus

public class LocalMessageBus
extends MessageBusSupport
implements org.springframework.context.ApplicationContextAware, org.springframework.beans.factory.InitializingBean

A simple implementation of MessageBus for in-process use. For inbound and outbound, creates a DirectChannel or a QueueChannel depending on whether the binding is aliased or not then bridges the passed MessageChannel to the channel which is registered in the given application context. If that channel does not yet exist, it will be created.

Since:

1.0

Author:

David Turanski, Mark Fisher, Gary Russell, Jennifer Hickey

Field Summary

Fields inherited from class org.springframework.integration.x.bus.MessageBusSupport

logger, MEDIATYPES_MEDIATYPE_ALL, ORIGINAL_CONTENT_TYPE_HEADER

Constructor Summary

Constructors

Constructor and Description
LocalMessageBus()

Method Summary

Methods

Modifier and Type	Method and Description
void	afterPropertiesSet()
void	bindConsumer(java.lang.String name, org.springframework.messaging.MessageChannel moduleInputChannel, boolean aliasHint) Looks up or creates a DirectChannel with the given name and creates a bridge from that channel to the provided channel instance.
void	bindProducer(java.lang.String name, org.springframework.messaging.MessageChannel moduleOutputChannel, boolean aliasHint) Looks up or creates a DirectChannel with the given name and creates a bridge to that channel from the provided channel instance.
void	bindPubSubConsumer(java.lang.String name, org.springframework.messaging.MessageChannel moduleInputChannel) Bind a message consumer on a pub/sub channel
void	bindPubSubProducer(java.lang.String name, org.springframework.messaging.MessageChannel moduleOutputChannel) Bind a message producer on a pub/sub channel.
void	bindReplier(java.lang.String name, org.springframework.messaging.MessageChannel requests, org.springframework.messaging.MessageChannel replies) Bind a consumer that handles requests from a requestor and asynchronously sends replies.
void	bindRequestor(java.lang.String name, org.springframework.messaging.MessageChannel requests, org.springframework.messaging.MessageChannel replies) Bind a producer that expects async replies.
protected org.springframework.integration.handler.BridgeHandler	bridge(org.springframework.messaging.MessageChannel from, org.springframework.messaging.MessageChannel to, java.lang.String bridgeName)
protected org.springframework.integration.handler.BridgeHandler	bridge(org.springframework.messaging.MessageChannel from, org.springframework.messaging.MessageChannel to, java.lang.String bridgeName, java.util.Collection<org.springframework.http.MediaType> acceptedMediaTypes)
protected <T extends org.springframework.integration.channel.AbstractMessageChannel> T	createSharedChannel(java.lang.String name, java.lang.Class<T> requiredType)
protected <T> T	getBean(java.lang.String name, java.lang.Class<T> requiredType)
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
void	setPoller(org.springframework.integration.scheduling.PollerMetadata poller) Set the poller to use when QueueChannels are used.
void	setQueueSize(int queueSize) Set the size of the queue when using QueueChannels.
void	unbindProducer(java.lang.String name, org.springframework.messaging.MessageChannel channel) Unbind a specific p2p or pub/sub message producer

Methods inherited from class org.springframework.integration.x.bus.MessageBusSupport

addBinding, deleteBinding, deleteBindings, deserializePayloadIfNecessary, getBeanFactory, getIdGenerator, serializePayloadIfNecessary, setBeanFactory, setCodec, stopBindings, unbindConsumer, unbindConsumers, unbindProducers

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalMessageBus

public LocalMessageBus()

Method Detail

setQueueSize

public void setQueueSize(int queueSize)

Set the size of the queue when using QueueChannels.

setPoller

public void setPoller(org.springframework.integration.scheduling.PollerMetadata poller)

Set the poller to use when QueueChannels are used.

setApplicationContext

public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
                           throws org.springframework.beans.BeansException

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware

Throws:

org.springframework.beans.BeansException

afterPropertiesSet

public void afterPropertiesSet()
                        throws java.lang.Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

java.lang.Exception

bindConsumer

public void bindConsumer(java.lang.String name,
                org.springframework.messaging.MessageChannel moduleInputChannel,
                boolean aliasHint)

Looks up or creates a DirectChannel with the given name and creates a bridge from that channel to the provided channel instance.

Specified by:

bindConsumer in interface MessageBus

Parameters:

name - the logical identity of the message source

moduleInputChannel - the channel bound as a consumer

aliasHint - whether the provided name represents an alias and thus should support late binding

bindPubSubConsumer

public void bindPubSubConsumer(java.lang.String name,
                      org.springframework.messaging.MessageChannel moduleInputChannel)

Description copied from interface: MessageBus

Bind a message consumer on a pub/sub channel

Specified by:

bindPubSubConsumer in interface MessageBus

Parameters:

name - the logical identity of the message source

moduleInputChannel - the channel bound as a pub/sub consumer

bindProducer

public void bindProducer(java.lang.String name,
                org.springframework.messaging.MessageChannel moduleOutputChannel,
                boolean aliasHint)

Looks up or creates a DirectChannel with the given name and creates a bridge to that channel from the provided channel instance.

Specified by:

bindProducer in interface MessageBus

Parameters:

name - the logical identity of the message target

moduleOutputChannel - the channel bound as a producer

aliasHint - whether the provided name represents an alias and thus should support late binding

bindPubSubProducer

public void bindPubSubProducer(java.lang.String name,
                      org.springframework.messaging.MessageChannel moduleOutputChannel)

Description copied from interface: MessageBus

Bind a message producer on a pub/sub channel.

Specified by:

bindPubSubProducer in interface MessageBus

Parameters:

name - the logical identity of the message target

moduleOutputChannel - the channel bound as a producer

bindRequestor

public void bindRequestor(java.lang.String name,
                 org.springframework.messaging.MessageChannel requests,
                 org.springframework.messaging.MessageChannel replies)

Description copied from interface: MessageBus

Bind a producer that expects async replies. To unbind, invoke unbindProducer() and unbindConsumer().

Specified by:

bindRequestor in interface MessageBus

Parameters:

name - The name of the requestor.

requests - The request channel - sends requests.

replies - The reply channel - receives replies.

bindReplier

public void bindReplier(java.lang.String name,
               org.springframework.messaging.MessageChannel requests,
               org.springframework.messaging.MessageChannel replies)

Description copied from interface: MessageBus

Bind a consumer that handles requests from a requestor and asynchronously sends replies. To unbind, invoke unbindProducer() and unbindConsumer().

Specified by:

bindReplier in interface MessageBus

Parameters:

name - The name of the requestor for which this replier will handle requests.

requests - The request channel - receives requests.

replies - The reply channel - sends replies.

unbindProducer

public void unbindProducer(java.lang.String name,
                  org.springframework.messaging.MessageChannel channel)

Description copied from interface: MessageBus

Unbind a specific p2p or pub/sub message producer

Specified by:

unbindProducer in interface MessageBus

Overrides:

unbindProducer in class MessageBusSupport

Parameters:

name - the logical identity of the message target

channel - the channel bound as a producer

createSharedChannel

protected <T extends org.springframework.integration.channel.AbstractMessageChannel> T createSharedChannel(java.lang.String name,
                                                                                               java.lang.Class<T> requiredType)

bridge

protected org.springframework.integration.handler.BridgeHandler bridge(org.springframework.messaging.MessageChannel from,
                                                           org.springframework.messaging.MessageChannel to,
                                                           java.lang.String bridgeName)

bridge

protected org.springframework.integration.handler.BridgeHandler bridge(org.springframework.messaging.MessageChannel from,
                                                           org.springframework.messaging.MessageChannel to,
                                                           java.lang.String bridgeName,
                                                           java.util.Collection<org.springframework.http.MediaType> acceptedMediaTypes)

getBean

protected <T> T getBean(java.lang.String name,
            java.lang.Class<T> requiredType)