Package org.springframework.integration.channel

Class ExecutorChannel

java.lang.Object
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.channel.AbstractMessageChannel
org.springframework.integration.channel.AbstractSubscribableChannel
org.springframework.integration.channel.AbstractExecutorChannel
org.springframework.integration.channel.ExecutorChannel
All Implemented Interfaces:
Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, ExecutorChannelInterceptorAware, ExpressionCapable, IntegrationPattern, NamedComponent, IntegrationManagement, SubscribableChannelManagement, TrackableComponent, MessageChannel, SubscribableChannel, InterceptableChannel
public class ExecutorChannel extends AbstractExecutorChannel
An implementation of MessageChannel that delegates to an instance of UnicastingDispatcher which in turn delegates all dispatching invocations to an Executor.

NOTE: unlike DirectChannel, the ExecutorChannel does not support a shared transactional context between sender and handler, because the Executor typically does not block the sender's Thread since it uses another Thread for the dispatch. (SyncTaskExecutor is an exception but would provide no value for this channel. If synchronous dispatching is required, a DirectChannel should be used instead).

Since:
1.0.3
Author:
Mark Fisher, Gary Russell, Artem Bilan

  • Constructor Details

    • ExecutorChannel

      public ExecutorChannel(Executor executor)
      Create an ExecutorChannel that delegates to the provided Executor when dispatching Messages.

      The Executor must not be null.

      Parameters:
      executor - The executor.

    • ExecutorChannel

      public ExecutorChannel(Executor executor, LoadBalancingStrategy loadBalancingStrategy)
      Create an ExecutorChannel with a LoadBalancingStrategy that delegates to the provided Executor when dispatching Messages.

      The Executor must not be null.

      Parameters:
      executor - The executor.
      loadBalancingStrategy - The load balancing strategy implementation.

  • Method Details

    • 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.

    • getDispatcher

      protected UnicastingDispatcher getDispatcher()
      Specified by:
      getDispatcher in class AbstractSubscribableChannel

    • onInit

      public final void onInit()
      Description copied from class: IntegrationObjectSupport
      Subclasses may implement this for initialization logic.
      Overrides:
      onInit in class AbstractMessageChannel