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.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, 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, java.util.Collection<org.springframework.http.MediaType> acceptedMediaTypes, 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, 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 moduleOutputChannel) Bind a message producer on a pub/sub channel.
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	setCodec(MultiTypeCodec<java.lang.Object> codec)
void	setConvertWithinTransport(boolean convertWithinTransport) Determines whether any conversion logic is applied within the local transport.
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.

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

addBinding, deleteBinding, deleteBindings, stopBindings, transformPayloadForConsumerIfNecessary, transformPayloadForProducerIfNecessary, unbindConsumer, unbindConsumers, unbindProducer, 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

setConvertWithinTransport

public void setConvertWithinTransport(boolean convertWithinTransport)

Determines whether any conversion logic is applied within the local transport. When false, objects pass through without any modification; default true.

setCodec

public void setCodec(MultiTypeCodec<java.lang.Object> codec)

Overrides:

setCodec in class MessageBusSupport

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,
                java.util.Collection<org.springframework.http.MediaType> acceptedMediaTypes,
                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

acceptedMediaTypes - the media types supported by the channel

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,
                      java.util.Collection<org.springframework.http.MediaType> acceptedMediaTypes)

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

acceptedMediaTypes - the media types supported by the channel

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

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)