org.springframework.integration.channel

Class DefaultHeaderChannelRegistry

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.channel.DefaultHeaderChannelRegistry

All Implemented Interfaces:

Runnable, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.context.Lifecycle, ExpressionCapable, HeaderChannelRegistry, NamedComponent

public class DefaultHeaderChannelRegistry
extends IntegrationObjectSupport
implements HeaderChannelRegistry, org.springframework.context.Lifecycle, Runnable

Converts a channel to a name, retaining a reference to the channel keyed by the name. Allows a downstream BeanFactoryChannelResolver to find the channel by name in the event that the flow serialized the message at some point. Channels are expired after a configurable delay (60 seconds by default). The actual average expiry time will be 1.5x the delay.

Since:

3.0

Author:

Gary Russell, Artem Bilan

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<String,org.springframework.integration.channel.DefaultHeaderChannelRegistry.MessageChannelWrapper>	channels
protected static AtomicLong	id
protected String	uuid

Fields inherited from class org.springframework.integration.context.IntegrationObjectSupport

EXPRESSION_PARSER, logger

Constructor Summary

Constructors

Constructor and Description
DefaultHeaderChannelRegistry() Constructs a registry with the default delay for channel expiry.
DefaultHeaderChannelRegistry(long reaperDelay) Constructs a registry with the provided delay (milliseconds) for channel expiry.

Method Summary

Modifier and Type	Method and Description
org.springframework.messaging.MessageChannel	channelNameToChannel(String name) Converts the channel name back to a MessageChannel (if it is registered).
Object	channelToChannelName(Object channel) Converts the channel to a name (String).
Object	channelToChannelName(Object channel, long timeToLive) Converts the channel to a name (String).
long	getReaperDelay()
boolean	isRunning()
protected void	onInit() Subclasses may implement this for initialization logic.
void	run()
void	runReaper() Cancel the scheduled reap task and run immediately; then reschedule.
void	setReaperDelay(long reaperDelay) Set the reaper delay.
void	setRemoveOnGet(boolean removeOnGet) Set to true to immediately remove the channel mapping when channelNameToChannel(String) is invoked.
void	setTaskScheduler(org.springframework.scheduling.TaskScheduler taskScheduler)
int	size()
void	start()
void	stop()
void	stop(Runnable callback)

Methods inherited from class org.springframework.integration.context.IntegrationObjectSupport

afterPropertiesSet, extractTypeIfPossible, getApplicationContext, getApplicationContextId, getBeanFactory, getChannelResolver, getComponentName, getComponentType, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, toString

Methods inherited from class java.lang.Object

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

Field Detail

channels

protected final Map<String,org.springframework.integration.channel.DefaultHeaderChannelRegistry.MessageChannelWrapper> channels

id

protected static final AtomicLong id

uuid

protected final String uuid

Constructor Detail

DefaultHeaderChannelRegistry

public DefaultHeaderChannelRegistry()

Constructs a registry with the default delay for channel expiry.

DefaultHeaderChannelRegistry

public DefaultHeaderChannelRegistry(long reaperDelay)

Constructs a registry with the provided delay (milliseconds) for channel expiry.

Parameters:

reaperDelay - the delay in milliseconds.

Method Detail

setReaperDelay

public final void setReaperDelay(long reaperDelay)

Set the reaper delay.

Parameters:

reaperDelay - the delay in milliseconds.

getReaperDelay

public final long getReaperDelay()

setRemoveOnGet

public void setRemoveOnGet(boolean removeOnGet)

Set to true to immediately remove the channel mapping when channelNameToChannel(String) is invoked.

Parameters:

removeOnGet - true to remove immediately, default false.

Since:

4.1

setTaskScheduler

public void setTaskScheduler(org.springframework.scheduling.TaskScheduler taskScheduler)

Overrides:

setTaskScheduler in class IntegrationObjectSupport

size

public final int size()

Specified by:

size in interface HeaderChannelRegistry

Returns:

the current size of the registry

onInit

protected void onInit()
               throws Exception

Description copied from class: IntegrationObjectSupport

Subclasses may implement this for initialization logic.

Overrides:

onInit in class IntegrationObjectSupport

Throws:

Exception - Any exception.

start

public void start()

Specified by:

start in interface org.springframework.context.Lifecycle

stop

public void stop()

Specified by:

stop in interface org.springframework.context.Lifecycle

stop

public void stop(Runnable callback)

isRunning

public boolean isRunning()

Specified by:

isRunning in interface org.springframework.context.Lifecycle

channelToChannelName

public Object channelToChannelName(Object channel)

Description copied from interface: HeaderChannelRegistry

Converts the channel to a name (String). If the channel is not a MessageChannel, it is returned unchanged.

Specified by:

channelToChannelName in interface HeaderChannelRegistry

Parameters:

channel - The channel.

Returns:

The channel name, or the channel if it is not a MessageChannel.

channelToChannelName

public Object channelToChannelName(Object channel,
                                   long timeToLive)

Description copied from interface: HeaderChannelRegistry

Converts the channel to a name (String). If the channel is not a MessageChannel, it is returned unchanged.

Specified by:

channelToChannelName in interface HeaderChannelRegistry

Parameters:

channel - The channel.

timeToLive - How long (ms) at a minimum, the channel mapping should remain in the registry.

Returns:

The channel name, or the channel if it is not a MessageChannel.

channelNameToChannel

public org.springframework.messaging.MessageChannel channelNameToChannel(String name)

Description copied from interface: HeaderChannelRegistry

Converts the channel name back to a MessageChannel (if it is registered).

Specified by:

channelNameToChannel in interface HeaderChannelRegistry

Parameters:

name - The name of the channel.

Returns:

The channel, or null if there is no channel registered with the name.

runReaper

public void runReaper()

Cancel the scheduled reap task and run immediately; then reschedule.

Specified by:

runReaper in interface HeaderChannelRegistry

run

public void run()

Specified by:

run in interface Runnable