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.DisposableBean, MessageBus

public class RedisMessageBus
extends MessageBusSupport
implements org.springframework.beans.factory.DisposableBean

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

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

addBinding, deleteBinding, deleteBindings, setCodec, 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

RedisMessageBus

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

Method Detail

bindConsumer

public void bindConsumer(java.lang.String name,
                org.springframework.messaging.MessageChannel moduleInputChannel,
                java.util.Collection<org.springframework.http.MediaType> acceptedMediaTypes,
                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

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)

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

destroy

public void destroy()

Specified by:

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