Class ScatterGatherSpec

java.lang.Object
org.springframework.beans.factory.config.AbstractFactoryBean<T>
All Implemented Interfaces:
org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanClassLoaderAware, org.springframework.beans.factory.BeanFactoryAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.FactoryBean<reactor.util.function.Tuple2<ConsumerEndpointFactoryBean,ScatterGatherHandler>>, org.springframework.beans.factory.InitializingBean, org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, ComponentsRegistration

public class ScatterGatherSpec extends ConsumerEndpointSpec<ScatterGatherSpec,ScatterGatherHandler>
Since:
5.0
See Also:
  • Constructor Details

  • Method Details

    • gatherChannel

      public ScatterGatherSpec gatherChannel(org.springframework.messaging.MessageChannel gatherChannel)
      Specify a MessageChannel (optional) which is used internally in the ScatterGatherHandler for gathering (aggregate) results for scattered requests.
      Parameters:
      gatherChannel - the MessageChannel for gathering results.
      Returns:
      the current ScatterGatherSpec instance.
    • gatherTimeout

      public ScatterGatherSpec gatherTimeout(long gatherTimeout)
      Specify a timeout (in milliseconds) for the PollableChannel.receive(long) operation to wait for gathering results to output. Defaults to -1 - to wait indefinitely.
      Parameters:
      gatherTimeout - the PollableChannel receive timeout.
      Returns:
      the current ScatterGatherSpec instance.
    • errorChannel

      public ScatterGatherSpec errorChannel(String errorChannel)
      Specify a MessageChannel bean name for async error processing. Defaults to IntegrationContextUtils.ERROR_CHANNEL_BEAN_NAME.
      Parameters:
      errorChannel - the MessageChannel bean name for async error processing.
      Returns:
      the current ScatterGatherSpec instance.
      Since:
      5.1.3