org.springframework.integration.x.channel.registry

Class LocalChannelRegistry

java.lang.Object

org.springframework.integration.x.channel.registry.LocalChannelRegistry

All Implemented Interfaces:

org.springframework.beans.factory.Aware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, ChannelRegistry

public class LocalChannelRegistry
extends java.lang.Object
implements ChannelRegistry, org.springframework.context.ApplicationContextAware, org.springframework.beans.factory.InitializingBean

A simple implementation of ChannelRegistry for in-process use. For inbound and outbound, creates a DirectChannel and bridges the passed MessageChannel to the channel which is registered in the given application context. If that channel does not yet exist, it will be created. For tap, it adds a WireTap for an inbound channel whose name matches the one provided. If no such inbound channel exists at the time of the method invocation, it will throw an Exception. Otherwise the provided channel instance will receive messages from the wire tap on that inbound channel.

Since:

1.0

Author:

David Turanski, Mark Fisher, Gary Russell

Constructor Summary

Constructors

Constructor and Description
LocalChannelRegistry()

Method Summary

Methods

Modifier and Type	Method and Description
void	afterPropertiesSet()
protected org.springframework.integration.handler.BridgeHandler	bridge(org.springframework.integration.core.SubscribableChannel from, org.springframework.integration.MessageChannel to, java.lang.String bridgeName)
protected org.springframework.integration.handler.BridgeHandler	bridge(org.springframework.integration.core.SubscribableChannel from, org.springframework.integration.MessageChannel to, java.lang.String bridgeName, java.lang.String tapModule)
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.
protected <T extends org.springframework.integration.channel.AbstractMessageChannel> T	createSharedChannel(java.lang.String name, java.lang.Class<T> requiredType)
void	inbound(java.lang.String name, org.springframework.integration.MessageChannel channel) Looks up or creates a DirectChannel with the given name and creates a bridge from that channel to the provided channel instance.
protected <T extends org.springframework.integration.channel.AbstractMessageChannel> T	lookupOrCreateSharedChannel(java.lang.String name, java.lang.Class<T> requiredType)
protected <T extends org.springframework.integration.channel.AbstractMessageChannel> T	lookupSharedChannel(java.lang.String name, java.lang.Class<T> requiredType)
void	outbound(java.lang.String name, org.springframework.integration.MessageChannel channel) Looks up or creates a DirectChannel with the given name and creates a bridge to that channel from the provided channel instance.
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
void	tap(java.lang.String tapModule, java.lang.String name, org.springframework.integration.MessageChannel channel) Looks up a wiretap for the inbound channel with the given name and creates a bridge from that wiretap's output channel to the provided channel instance.

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalChannelRegistry

public LocalChannelRegistry()

Method Detail

setApplicationContext

public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
                           throws org.springframework.beans.BeansException

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware

Throws:

org.springframework.beans.BeansException

afterPropertiesSet

public void afterPropertiesSet()
                        throws java.lang.Exception

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Throws:

java.lang.Exception

inbound

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

Looks up or creates a DirectChannel with the given name and creates a bridge from that channel to the provided channel instance. Also registers a wire tap if the channel for the given name had been created. The target of the wire tap is a publish-subscribe channel.

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)

Looks up or creates a DirectChannel with the given name and creates a bridge to that channel from the provided channel instance.

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)

Looks up a wiretap for the inbound channel with the given name and creates a bridge from that wiretap's output channel to the provided channel instance. Will throw an Exception if no such wiretap exists.

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

lookupOrCreateSharedChannel

protected <T extends org.springframework.integration.channel.AbstractMessageChannel> T lookupOrCreateSharedChannel(java.lang.String name,
                                                                                                       java.lang.Class<T> requiredType)

lookupSharedChannel

protected <T extends org.springframework.integration.channel.AbstractMessageChannel> T lookupSharedChannel(java.lang.String name,
                                                                                               java.lang.Class<T> requiredType)

createSharedChannel

protected <T extends org.springframework.integration.channel.AbstractMessageChannel> T createSharedChannel(java.lang.String name,
                                                                                               java.lang.Class<T> requiredType)

bridge

protected org.springframework.integration.handler.BridgeHandler bridge(org.springframework.integration.core.SubscribableChannel from,
                                                           org.springframework.integration.MessageChannel to,
                                                           java.lang.String bridgeName)

bridge

protected org.springframework.integration.handler.BridgeHandler bridge(org.springframework.integration.core.SubscribableChannel from,
                                                           org.springframework.integration.MessageChannel to,
                                                           java.lang.String bridgeName,
                                                           java.lang.String tapModule)