public class ScatterGatherSpec extends ConsumerEndpointSpec<ScatterGatherSpec,org.springframework.integration.scattergather.ScatterGatherHandler>
GenericEndpointSpec extension for the ScatterGatherHandler.ScatterGatherHandlercomponentToRegisterid, logger, PARSER, target| Modifier and Type | Method and Description |
|---|---|
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. |
ScatterGatherSpec |
gatherTimeout(long gatherTimeout)
Specify a timeout (in milliseconds) for the
PollableChannel.receive(long) operation
to wait for gathering results to output. |
advice, autoStartup, order, phase, poller, requiresReply, sendTimeout, transactional, transactional, transactional, transactional, transactionalgetComponentsToRegister, id, poller, poller_this, doGet, get, getId, getObject, getObjectType, isSingletonpublic ScatterGatherSpec gatherChannel(org.springframework.messaging.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.