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:

BeanFactoryAware, BeanNameAware, InitializingBean, MessageChannel, SubscribableChannel, NamedComponent

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

Nested Class Summary

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

AbstractMessageChannel.ChannelInterceptorList

Constructor Summary

DirectChannel()
Create a channel with default RoundRobinLoadBalancingStrategy

DirectChannel(LoadBalancingStrategy loadBalancingStrategy)
Create a DirectChannel with a LoadBalancingStrategy.

Method Summary

protected UnicastingDispatcher	getDispatcher()
void	setFailover(boolean failover) Specify whether the channel's dispatcher should have failover enabled.

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

doSend, subscribe, unsubscribe

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

addInterceptor, getComponentType, getInterceptors, getSendErrorCount, getSendSuccessCount, send, send, setConversionService, setDatatypes, setInterceptors

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

afterPropertiesSet, getBeanFactory, getChannelResolver, getComponentName, getConversionService, getTaskScheduler, onInit, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setTaskScheduler, toString, writeMessageHistory

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.integration.core.MessageChannel

send, send

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.

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.

getDispatcher

protected UnicastingDispatcher getDispatcher()

Specified by:

getDispatcher in class AbstractSubscribableChannel