org.springframework.integration.router

Class RecipientListRouter

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.handler.AbstractMessageHandler

org.springframework.integration.router.AbstractMessageRouter

org.springframework.integration.router.RecipientListRouter

All Implemented Interfaces:

org.reactivestreams.Subscriber<org.springframework.messaging.Message<?>>, 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.core.Ordered, ExpressionCapable, Orderable, MessageRouter, RecipientListRouterManagement, NamedComponent, ConfigurableMetricsAware<AbstractMessageHandlerMetrics>, IntegrationManagement, IntegrationStatsManagement, MessageHandlerMetrics, TrackableComponent, org.springframework.messaging.MessageHandler, reactor.core.CoreSubscriber<org.springframework.messaging.Message<?>>

public class RecipientListRouter
extends AbstractMessageRouter
implements org.springframework.beans.factory.InitializingBean, RecipientListRouterManagement

 <recipient-list-router id="simpleRouter" input-channel="routingChannelA">
     <recipient channel="channel1"/>
     <recipient channel="channel2"/>
 </recipient-list-router>
 
 

A Message Router that sends Messages to a list of recipient channels. The recipients can be provided as a static list of MessageChannel instances via the setChannels(List) method, or for dynamic behavior, the values can be provided via the setRecipients(List) method.

For more advanced, programmatic control of dynamic recipient lists, consider using the @Router annotation or extending AbstractMappingMessageRouter instead.

Contrary to a standard <router .../> this handler will try to send to all channels that are configured as recipients. It is to channels what a publish subscribe channel is to endpoints.

Using this class only makes sense if it is essential to send messages on multiple channels instead of sending them to multiple handlers. If the latter is an option using a publish subscribe channel is the more flexible solution.

Author:

Mark Fisher, Oleg Zhurakousky, Artem Bilan, Liujiong

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	RecipientListRouter.Recipient

Nested classes/interfaces inherited from interface org.springframework.integration.support.management.IntegrationManagement

IntegrationManagement.ManagementOverrides

Field Summary

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

EXPRESSION_PARSER, logger

Fields inherited from interface org.springframework.integration.support.management.IntegrationManagement

METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAME

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor and Description
RecipientListRouter()

Method Summary

Modifier and Type	Method and Description
void	addRecipient(org.springframework.messaging.MessageChannel channel)
void	addRecipient(org.springframework.messaging.MessageChannel channel, MessageSelector selector)
void	addRecipient(java.lang.String channelName) Add a recipient with channelName.
void	addRecipient(java.lang.String channelName, MessageSelector selector)
void	addRecipient(java.lang.String channelName, java.lang.String selectorExpression) Add a recipient with channelName and expression.
protected java.util.Collection<org.springframework.messaging.MessageChannel>	determineTargetChannels(org.springframework.messaging.Message<?> message) Subclasses must implement this method to return a Collection of zero or more MessageChannels to which the given Message should be routed.
java.lang.String	getComponentType() Subclasses may implement this method to provide component type information.
java.util.Collection<RecipientListRouter.Recipient>	getRecipients()
protected void	onInit() Subclasses may implement this for initialization logic.
int	removeRecipient(java.lang.String channelName) Remove all recipients that match the channelName.
int	removeRecipient(java.lang.String channelName, java.lang.String selectorExpression) Remove all recipients that match the channelName and expression.
void	replaceRecipients(java.util.Properties recipientMappings) Replace recipient.
void	setChannels(java.util.List<org.springframework.messaging.MessageChannel> channels) Set the channels for this router.
void	setRecipientMappings(java.util.Map<java.lang.String,java.lang.String> recipientMappings) Set the recipients for this router.
void	setRecipients(java.util.List<RecipientListRouter.Recipient> recipients) Set the recipients for this router.

Methods inherited from class org.springframework.integration.router.AbstractMessageRouter

getDefaultOutputChannel, getMessagingTemplate, getRequiredConversionService, handleMessageInternal, setApplySequence, setDefaultOutputChannel, setDefaultOutputChannelName, setIgnoreSendFailures, setSendTimeout

Methods inherited from class org.springframework.integration.handler.AbstractMessageHandler

configureMetrics, getActiveCount, getActiveCountLong, getDuration, getErrorCount, getErrorCountLong, getHandleCount, getHandleCountLong, getManagedName, getManagedType, getMaxDuration, getMeanDuration, getMinDuration, getOrder, getOverrides, getStandardDeviationDuration, handleMessage, isCountsEnabled, isLoggingEnabled, isStatsEnabled, onComplete, onError, onNext, onSubscribe, registerMetricsCaptor, reset, setCountsEnabled, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, setStatsEnabled

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

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

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.beans.factory.InitializingBean

afterPropertiesSet

Methods inherited from interface org.springframework.integration.support.context.NamedComponent

getComponentName

Methods inherited from interface reactor.core.CoreSubscriber

currentContext

Constructor Detail

RecipientListRouter

public RecipientListRouter()

Method Detail

setChannels

public void setChannels(java.util.List<org.springframework.messaging.MessageChannel> channels)

Set the channels for this router. Either call this method or setRecipients(List) but not both. If MessageSelectors should be considered, then use setRecipients(List).

Parameters:

channels - The channels.

setRecipients

public void setRecipients(java.util.List<RecipientListRouter.Recipient> recipients)

Set the recipients for this router.

Parameters:

recipients - The recipients.

setRecipientMappings

@ManagedAttribute
public void setRecipientMappings(java.util.Map<java.lang.String,java.lang.String> recipientMappings)

Set the recipients for this router.

Specified by:

setRecipientMappings in interface RecipientListRouterManagement

Parameters:

recipientMappings - map contains channelName and expression

addRecipient

@ManagedOperation
public void addRecipient(java.lang.String channelName,
                                           java.lang.String selectorExpression)

Description copied from interface: RecipientListRouterManagement

Add a recipient with channelName and expression.

Specified by:

addRecipient in interface RecipientListRouterManagement

Parameters:

channelName - The channel name.

selectorExpression - The expression to filter the incoming message.

addRecipient

@ManagedOperation
public void addRecipient(java.lang.String channelName)

Description copied from interface: RecipientListRouterManagement

Add a recipient with channelName.

Specified by:

addRecipient in interface RecipientListRouterManagement

Parameters:

channelName - The channel name.

addRecipient

public void addRecipient(java.lang.String channelName,
                         MessageSelector selector)

addRecipient

public void addRecipient(org.springframework.messaging.MessageChannel channel)

addRecipient

public void addRecipient(org.springframework.messaging.MessageChannel channel,
                         MessageSelector selector)

removeRecipient

@ManagedOperation
public int removeRecipient(java.lang.String channelName)

Description copied from interface: RecipientListRouterManagement

Remove all recipients that match the channelName.

Specified by:

removeRecipient in interface RecipientListRouterManagement

Parameters:

channelName - The channel name.

Returns:

The number of recipients removed.

removeRecipient

@ManagedOperation
public int removeRecipient(java.lang.String channelName,
                                             java.lang.String selectorExpression)

Description copied from interface: RecipientListRouterManagement

Remove all recipients that match the channelName and expression.

Specified by:

removeRecipient in interface RecipientListRouterManagement

Parameters:

channelName - The channel name.

selectorExpression - The expression to filter the incoming message

Returns:

The number of recipients removed.

replaceRecipients

@ManagedOperation
public void replaceRecipients(java.util.Properties recipientMappings)

Description copied from interface: RecipientListRouterManagement

Replace recipient.

Specified by:

replaceRecipients in interface RecipientListRouterManagement

Parameters:

recipientMappings - contain channelName and expression.

getRecipients

@ManagedAttribute
public java.util.Collection<RecipientListRouter.Recipient> getRecipients()

Specified by:

getRecipients in interface RecipientListRouterManagement

Returns:

an unmodifiable collection of recipients.

getComponentType

public java.lang.String getComponentType()

Description copied from class: IntegrationObjectSupport

Subclasses may implement this method to provide component type information.

Specified by:

getComponentType in interface NamedComponent

Overrides:

getComponentType in class AbstractMessageRouter

determineTargetChannels

protected java.util.Collection<org.springframework.messaging.MessageChannel> determineTargetChannels(org.springframework.messaging.Message<?> message)

Description copied from class: AbstractMessageRouter

Subclasses must implement this method to return a Collection of zero or more MessageChannels to which the given Message should be routed.

Specified by:

determineTargetChannels in class AbstractMessageRouter

Parameters:

message - The message.

Returns:

The collection of message channels.

onInit

protected void onInit()
               throws java.lang.Exception

Description copied from class: IntegrationObjectSupport

Subclasses may implement this for initialization logic.

Overrides:

onInit in class AbstractMessageRouter

Throws:

java.lang.Exception - Any exception.