org.springframework.integration.channel
Class DirectChannel

java.lang.Object
  org.springframework.integration.channel.AbstractMessageChannel
      org.springframework.integration.channel.AbstractSubscribableChannel
          org.springframework.integration.channel.DirectChannel

All Implemented Interfaces:

org.springframework.beans.factory.BeanNameAware, SubscribableChannel, MessageChannel

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

Nested Class Summary

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

AbstractMessageChannel.ChannelInterceptorList

Constructor Summary

DirectChannel()
Create a channel with no LoadBalancingStrategy.

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, getInterceptors, getName, send, send, setBeanName, setInterceptors, toString

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

getName, send, send

Constructor Detail

DirectChannel

public DirectChannel()

Create a channel with no LoadBalancingStrategy. The dispatcher for such a channel will invoke its MessageHandlers in a fixed-order.

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