org.springframework.integration.x.redis

Class RedisMessageBus

java.lang.Object

org.springframework.integration.x.bus.MessageBusSupport

org.springframework.integration.x.redis.RedisMessageBus

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.DisposableBean, org.springframework.integration.expression.IntegrationEvaluationContextAware, MessageBus

public class RedisMessageBus
extends MessageBusSupport
implements org.springframework.beans.factory.DisposableBean, org.springframework.integration.expression.IntegrationEvaluationContextAware

A MessageBus implementation backed by Redis.

Author:

Mark Fisher, Gary Russell, David Turanski, 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
RedisMessageBus(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory, MultiTypeCodec<java.lang.Object> codec)

Method Summary

Methods

Modifier and Type	Method and Description
void	bindConsumer(java.lang.String name, org.springframework.messaging.MessageChannel moduleInputChannel, 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 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.
void	destroy()
void	setIntegrationEvaluationContext(org.springframework.expression.EvaluationContext context)

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

RedisMessageBus

public RedisMessageBus(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory,
               MultiTypeCodec<java.lang.Object> codec)

Method Detail

setIntegrationEvaluationContext

public void setIntegrationEvaluationContext(org.springframework.expression.EvaluationContext context)

Specified by:

setIntegrationEvaluationContext in interface org.springframework.integration.expression.IntegrationEvaluationContextAware

bindConsumer

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

Description copied from interface: MessageBus

Bind a message consumer on a p2p channel

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)

Description copied from interface: MessageBus

Bind a message producer on a p2p channel.

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.

destroy

public void destroy()

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean