org.springframework.integration.x.bus

Class MessageBusSupport

java.lang.Object

org.springframework.integration.x.bus.MessageBusSupport

All Implemented Interfaces:

MessageBus

Direct Known Subclasses:

LocalMessageBus, RabbitMessageBus, RedisMessageBus

public abstract class MessageBusSupport
extends java.lang.Object
implements MessageBus

Author:

David Turanski, Gary Russell

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.commons.logging.Log	logger
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)
void	setCodec(MultiTypeCodec<java.lang.Object> codec)
protected void	stopBindings()
protected org.springframework.messaging.Message<?>	transformPayloadForConsumerIfNecessary(org.springframework.messaging.Message<?> message, java.util.Collection<org.springframework.http.MediaType> acceptedMediaTypes)
protected org.springframework.messaging.Message<?>	transformPayloadForProducerIfNecessary(org.springframework.messaging.Message<?> message, org.springframework.http.MediaType to)
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

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

Constructor Detail

MessageBusSupport

public MessageBusSupport()

Method Detail

setCodec

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

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()

transformPayloadForProducerIfNecessary

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

transformPayloadForConsumerIfNecessary

protected final org.springframework.messaging.Message<?> transformPayloadForConsumerIfNecessary(org.springframework.messaging.Message<?> message,
                                                                              java.util.Collection<org.springframework.http.MediaType> acceptedMediaTypes)