public class ScatterGatherSpec extends ConsumerEndpointSpec<ScatterGatherSpec,ScatterGatherHandler>
GenericEndpointSpec extension for the ScatterGatherHandler.ScatterGatherHandleradviceChaincomponentsToRegister, endpointFactoryBean, handlerPARSER, targetloggerDEFAULT_PHASE| Modifier and Type | Method and Description |
|---|---|
ScatterGatherSpec |
errorChannel(String errorChannel)
Specify a
MessageChannel bean name for async error processing. |
ScatterGatherSpec |
gatherChannel(MessageChannel gatherChannel)
Specify a
MessageChannel (optional) which is used internally
in the ScatterGatherHandler for gathering (aggregate) results for scattered requests. |
ScatterGatherSpec |
gatherTimeout(long gatherTimeout)
Specify a timeout (in milliseconds) for the
PollableChannel.receive(long) operation
to wait for gathering results to output. |
advice, async, autoStartup, doGet, notPropagatedHeaders, order, phase, poller, requiresReply, role, sendTimeout, taskScheduler, transactional, transactional, transactional, transactional, transactionalassertHandler, getComponentsToRegister, id, obtainInputChannelFromFlow, obtainInputChannelFromFlow, poller, poller_this, createInstance, destroyInstance, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stopafterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingletonpublic ScatterGatherSpec gatherChannel(MessageChannel gatherChannel)
MessageChannel (optional) which is used internally
in the ScatterGatherHandler for gathering (aggregate) results for scattered requests.gatherChannel - the MessageChannel for gathering results.ScatterGatherSpec instance.public ScatterGatherSpec gatherTimeout(long gatherTimeout)
PollableChannel.receive(long) operation
to wait for gathering results to output.
Defaults to -1 - to wait indefinitely.gatherTimeout - the PollableChannel receive timeout.ScatterGatherSpec instance.public ScatterGatherSpec errorChannel(String errorChannel)
MessageChannel bean name for async error processing. Defaults to
IntegrationContextUtils.ERROR_CHANNEL_BEAN_NAME.errorChannel - the MessageChannel bean name for async error
processing.ScatterGatherSpec instance.