org.springframework.integration.x.redis

Class RedisChannelRegistry

java.lang.Object

org.springframework.integration.x.redis.RedisChannelRegistry

All Implemented Interfaces:

org.springframework.beans.factory.DisposableBean, ChannelRegistry

public class RedisChannelRegistry
extends java.lang.Object
implements ChannelRegistry, org.springframework.beans.factory.DisposableBean

A ChannelRegistry implementation backed by Redis.

Author:

Mark Fisher, Gary Russell, David Turanski

Constructor Summary

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanAll(java.lang.String name) Remove all subscriptions to inter-module channels for this module and stop any active components that use those channels.
void	destroy()
void	inbound(java.lang.String name, org.springframework.integration.MessageChannel channel) Register a message consumer
void	outbound(java.lang.String name, org.springframework.integration.MessageChannel channel) Register a message producer
void	tap(java.lang.String tapModule, java.lang.String name, org.springframework.integration.MessageChannel channel) Create a tap on an already registered inbound channel

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

inbound

public void inbound(java.lang.String name,
           org.springframework.integration.MessageChannel channel)

Description copied from interface: ChannelRegistry

Register a message consumer

Specified by:

inbound in interface ChannelRegistry

Parameters:

name - the logical identity of the message source

channel - the channel bound as a consumer

outbound

public void outbound(java.lang.String name,
            org.springframework.integration.MessageChannel channel)

Description copied from interface: ChannelRegistry

Register a message producer

Specified by:

outbound in interface ChannelRegistry

Parameters:

name - the logical identity of the message target

channel - the channel bound as a producer

tap

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

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

channel - the channel that will receive messages from the tap

cleanAll

public void cleanAll(java.lang.String name)

Description copied from interface: ChannelRegistry

Remove all subscriptions to inter-module channels for this module and stop any active components that use those channels.

Specified by:

cleanAll in interface ChannelRegistry

Parameters:

name - the module name

destroy

public void destroy()

Specified by:

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