org.springframework.integration.x.bus

Class MessageBusSupport

java.lang.Object

org.springframework.integration.x.bus.MessageBusSupport

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, MessageBus

Direct Known Subclasses:

LocalMessageBus, RabbitMessageBus, RedisMessageBus

public abstract class MessageBusSupport
extends java.lang.Object
implements MessageBus, org.springframework.beans.factory.BeanFactoryAware

Author:

David Turanski, Gary Russell

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.commons.logging.Log	logger
protected static java.util.List<org.springframework.http.MediaType>	MEDIATYPES_MEDIATYPE_ALL
protected static java.lang.String	ORIGINAL_CONTENT_TYPE_HEADER

Constructor Summary

Constructors

Constructor and Description
MessageBusSupport()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	addBinding(Binding binding)
protected void	deleteBinding(java.lang.String name, org.springframework.messaging.MessageChannel channel)
protected void	deleteBindings(java.lang.String name)
protected org.springframework.messaging.Message<?>	deserializePayloadIfNecessary(org.springframework.messaging.Message<?> message)
protected org.springframework.beans.factory.BeanFactory	getBeanFactory()
protected org.springframework.util.IdGenerator	getIdGenerator()
protected org.springframework.messaging.Message<?>	serializePayloadIfNecessary(org.springframework.messaging.Message<?> message, org.springframework.http.MediaType to)
void	setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
void	setCodec(MultiTypeCodec<java.lang.Object> codec)
protected void	stopBindings()
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.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.integration.x.bus.MessageBus

bindConsumer, bindProducer, bindPubSubConsumer, bindPubSubProducer, bindReplier, bindRequestor

Field Detail

logger

protected final org.apache.commons.logging.Log logger

ORIGINAL_CONTENT_TYPE_HEADER

protected static final java.lang.String ORIGINAL_CONTENT_TYPE_HEADER

See Also:

Constant Field Values

MEDIATYPES_MEDIATYPE_ALL

protected static final java.util.List<org.springframework.http.MediaType> MEDIATYPES_MEDIATYPE_ALL

Constructor Detail

MessageBusSupport

public MessageBusSupport()

Method Detail

setBeanFactory

public void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
                    throws org.springframework.beans.BeansException

Specified by:

setBeanFactory in interface org.springframework.beans.factory.BeanFactoryAware

Throws:

org.springframework.beans.BeansException

getBeanFactory

protected org.springframework.beans.factory.BeanFactory getBeanFactory()

setCodec

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

getIdGenerator

protected org.springframework.util.IdGenerator getIdGenerator()

unbindConsumers

public void unbindConsumers(java.lang.String name)

Description copied from interface: MessageBus

Unbind an inbound inter-module channel and stop any active components that use the channel.

Specified by:

unbindConsumers in interface MessageBus

Parameters:

name - the channel name

unbindProducers

public void unbindProducers(java.lang.String name)

Description copied from interface: MessageBus

Unbind an outbound inter-module channel and stop any active components that use the channel.

Specified by:

unbindProducers in interface MessageBus

Parameters:

name - the channel name

unbindConsumer

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

Description copied from interface: MessageBus

Unbind a specific p2p or pub/sub message consumer

Specified by:

unbindConsumer in interface MessageBus

Parameters:

name - The logical identify of a message source

channel - The channel bound as a consumer

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

Parameters:

name - the logical identity of the message target

channel - the channel bound as a producer

addBinding

protected void addBinding(Binding binding)

deleteBindings

protected void deleteBindings(java.lang.String name)

deleteBinding

protected void deleteBinding(java.lang.String name,
                 org.springframework.messaging.MessageChannel channel)

stopBindings

protected void stopBindings()

serializePayloadIfNecessary

protected final org.springframework.messaging.Message<?> serializePayloadIfNecessary(org.springframework.messaging.Message<?> message,
                                                                   org.springframework.http.MediaType to)

deserializePayloadIfNecessary

protected final org.springframework.messaging.Message<?> deserializePayloadIfNecessary(org.springframework.messaging.Message<?> message)