org.springframework.integration.x.redis

Class RedisChannelRegistry

java.lang.Object

org.springframework.integration.x.channel.registry.ChannelRegistrySupport

org.springframework.integration.x.redis.RedisChannelRegistry

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanClassLoaderAware, org.springframework.beans.factory.DisposableBean, ChannelRegistry

public class RedisChannelRegistry
extends ChannelRegistrySupport
implements org.springframework.beans.factory.DisposableBean

A ChannelRegistry implementation backed by Redis.

Author:

Mark Fisher, Gary Russell, David Turanski

Field Summary

Fields inherited from class org.springframework.integration.x.channel.registry.ChannelRegistrySupport

ORIGINAL_CONTENT_TYPE_HEADER, XD_JSON_OCTET_STREAM_VALUE, XD_OCTET_STREAM_VALUE, XD_TEXT_PLAIN_UTF8_VALUE

Constructor Summary

Constructors

Constructor and Description
RedisChannelRegistry(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)

Method Summary

Methods

Modifier and Type	Method and Description
void	createInbound(java.lang.String name, org.springframework.integration.MessageChannel moduleInputChannel, java.util.Collection<org.springframework.http.MediaType> acceptedMediaTypes, boolean aliasHint) Register a message consumer.
void	createOutbound(java.lang.String name, org.springframework.integration.MessageChannel moduleOutputChannel, boolean aliasHint) Register a message producer.
void	deleteInbound(java.lang.String name) Remove an inbound inter-module channel and stop any active components that use the channel.
void	deleteOutbound(java.lang.String name) Remove an outbound inter-module channel and stop any active components that use the channel.
void	destroy()
void	tap(java.lang.String tapModule, java.lang.String name, org.springframework.integration.MessageChannel tapModuleInputChannel) Create a tap on an already registered inbound channel.

Methods inherited from class org.springframework.integration.x.channel.registry.ChannelRegistrySupport

setBeanClassLoader, setConversionService, transformInboundIfNecessary, transformOutboundIfNecessary

Methods inherited from class java.lang.Object

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

Constructor Detail

RedisChannelRegistry

public RedisChannelRegistry(org.springframework.data.redis.connection.RedisConnectionFactory connectionFactory)

Method Detail

createInbound

public void createInbound(java.lang.String name,
                 org.springframework.integration.MessageChannel moduleInputChannel,
                 java.util.Collection<org.springframework.http.MediaType> acceptedMediaTypes,
                 boolean aliasHint)

Description copied from interface: ChannelRegistry

Register a message consumer.

Specified by:

createInbound in interface ChannelRegistry

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

createOutbound

public void createOutbound(java.lang.String name,
                  org.springframework.integration.MessageChannel moduleOutputChannel,
                  boolean aliasHint)

Description copied from interface: ChannelRegistry

Register a message producer.

Specified by:

createOutbound in interface ChannelRegistry

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

tap

public void tap(java.lang.String tapModule,
       java.lang.String name,
       org.springframework.integration.MessageChannel tapModuleInputChannel)

Description copied from interface: ChannelRegistry

Create a tap on an already registered inbound channel.

Specified by:

tap in interface ChannelRegistry

Parameters:

tapModule - the name of the tap module

name - the registered name

tapModuleInputChannel - the channel that will receive messages from the tap

deleteInbound

public void deleteInbound(java.lang.String name)

Description copied from interface: ChannelRegistry

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

Specified by:

deleteInbound in interface ChannelRegistry

Parameters:

name - the channel name

deleteOutbound

public void deleteOutbound(java.lang.String name)

Description copied from interface: ChannelRegistry

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

Specified by:

deleteOutbound in interface ChannelRegistry

Parameters:

name - the channel name

destroy

public void destroy()

Specified by:

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