org.springframework.integration.router
Class MultiChannelRouter

java.lang.Object
  org.springframework.integration.router.AbstractRoutingMessageHandler
      org.springframework.integration.router.MultiChannelRouter

All Implemented Interfaces:

org.springframework.beans.factory.InitializingBean, ChannelRegistryAware, MessageHandler

Direct Known Subclasses:

RecipientListRouter

public class MultiChannelRouter
extends AbstractRoutingMessageHandler

A router implementation for sending to potentially multiple MessageChannels. Requires either a MultiChannelResolver or MultiChannelNameResolver strategy instance. In the case of the latter, the ChannelRegistry reference must also be provided. For convenience, the superclass does implement ChannelRegistryAware.

Author:

Mark Fisher

Field Summary

private MultiChannelNameResolver	channelNameResolver
private MultiChannelResolver	channelResolver

Fields inherited from class org.springframework.integration.router.AbstractRoutingMessageHandler

logger

Constructor Summary

MultiChannelRouter()

Method Summary

java.util.List<MessageChannel>	resolveChannels(Message<?> message)
void	setChannelNameResolver(MultiChannelNameResolver channelNameResolver)
void	setChannelResolver(MultiChannelResolver channelResolver)
void	validate()

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

afterPropertiesSet, getChannelRegistry, handle, setChannelRegistry, setResolutionRequired, setTimeout

Methods inherited from class java.lang.Object

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

Field Detail

channelResolver

private MultiChannelResolver channelResolver

channelNameResolver

private MultiChannelNameResolver channelNameResolver

Constructor Detail

MultiChannelRouter

public MultiChannelRouter()

Method Detail

setChannelResolver

public void setChannelResolver(MultiChannelResolver channelResolver)

setChannelNameResolver

public void setChannelNameResolver(MultiChannelNameResolver channelNameResolver)

validate

public void validate()

Specified by:

validate in class AbstractRoutingMessageHandler

resolveChannels

public java.util.List<MessageChannel> resolveChannels(Message<?> message)

Specified by:

resolveChannels in class AbstractRoutingMessageHandler