org.springframework.integration.channel

Class DirectChannel

java.lang.Object

org.springframework.integration.context.IntegrationObjectSupport

org.springframework.integration.channel.AbstractMessageChannel

org.springframework.integration.channel.AbstractSubscribableChannel

org.springframework.integration.channel.DirectChannel

All Implemented Interfaces:

Aware, BeanFactoryAware, BeanNameAware, InitializingBean, ApplicationContextAware, ChannelInterceptorAware, TrackableComponent, NamedComponent, MessageChannel, SubscribableChannel

public class DirectChannel
extends AbstractSubscribableChannel

A channel that invokes a single subscriber for each sent Message. The invocation will occur in the sender's thread.

Author:

Dave Syer, Mark Fisher, Iwein Fuld, Oleg Zhurakousky, Gary Russell

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.integration.channel.AbstractMessageChannel

AbstractMessageChannel.ChannelInterceptorList

Field Summary

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

logger

Fields inherited from interface org.springframework.messaging.MessageChannel

INDEFINITE_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
DirectChannel() Create a channel with default RoundRobinLoadBalancingStrategy
DirectChannel(LoadBalancingStrategy loadBalancingStrategy) Create a DirectChannel with a LoadBalancingStrategy.

Method Summary

Methods

Modifier and Type	Method and Description
protected UnicastingDispatcher	getDispatcher()
protected void	onInit() Subclasses may implement this for initialization logic.
void	setFailover(boolean failover) Specify whether the channel's dispatcher should have failover enabled.
void	setMaxSubscribers(int maxSubscribers) Specify the maximum number of subscribers supported by the channel's dispatcher.

Methods inherited from class org.springframework.integration.channel.AbstractSubscribableChannel

doSend, subscribe, unsubscribe

Methods inherited from class org.springframework.integration.channel.AbstractMessageChannel

addInterceptor, addInterceptor, getChannelInterceptors, getComponentType, getFullChannelName, getInterceptors, send, send, setConversionService, setDatatypes, setInterceptors, setMessageConverter, setShouldTrack

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

afterPropertiesSet, getApplicationContextId, getBeanFactory, getComponentName, getConversionService, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, setApplicationContext, setBeanFactory, setBeanName, setComponentName, setMessageBuilderFactory, 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.messaging.MessageChannel

send, send

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

getComponentName

Constructor Detail

DirectChannel

public DirectChannel()

Create a channel with default RoundRobinLoadBalancingStrategy

DirectChannel

public DirectChannel(LoadBalancingStrategy loadBalancingStrategy)

Create a DirectChannel with a LoadBalancingStrategy. The strategy must not be null.

Parameters:

loadBalancingStrategy - The load balancing strategy implementation.

Method Detail

setFailover

public void setFailover(boolean failover)

Specify whether the channel's dispatcher should have failover enabled. By default, it will. Set this value to 'false' to disable it.

Parameters:

failover - The failover boolean.

setMaxSubscribers

public void setMaxSubscribers(int maxSubscribers)

Specify the maximum number of subscribers supported by the channel's dispatcher.

Parameters:

maxSubscribers - The maximum number of subscribers allowed.

getDispatcher

protected UnicastingDispatcher getDispatcher()

Specified by:

getDispatcher in class AbstractSubscribableChannel

onInit

protected void onInit()
               throws Exception

Description copied from class: IntegrationObjectSupport

Subclasses may implement this for initialization logic.

Overrides:

onInit in class AbstractMessageChannel

Throws:

Exception - Any exception.