org.springframework.integration.x.channel.registry

Interface ChannelRegistry

All Known Implementing Classes:

LocalChannelRegistry, RedisChannelRegistry

public interface ChannelRegistry

A strategy interface used to bind a MessageChannel to a logical name. The name is intended to identify a logical consumer or producer of messages. This may be a queue, a channel adapter, another message channel, a Spring bean, etc.

Since:

1.0

Author:

Mark Fisher, David Turanski, Gary Russell

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

Method Detail

inbound

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

Register a message consumer

Parameters:

name - the logical identity of the message source

channel - the channel bound as a consumer

outbound

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

Register a message producer

Parameters:

name - the logical identity of the message target

channel - the channel bound as a producer

tap

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

Create a tap on an already registered inbound channel

Parameters:

tapModule - the name of the tap module

name - the registered name

channel - the channel that will receive messages from the tap

cleanAll

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.

Parameters:

name - the module name