public class ScatterGatherSpec extends ConsumerEndpointSpec<ScatterGatherSpec,ScatterGatherHandler>
GenericEndpointSpec
extension for the ScatterGatherHandler
.ScatterGatherHandler
adviceChain
componentsToRegister, endpointFactoryBean, handler
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, async, autoStartup, doGet, notPropagatedHeaders, order, phase, poller, requiresReply, role, sendTimeout, taskScheduler, transactional, transactional, transactional, transactional, transactional
assertHandler, getComponentsToRegister, id, poller, poller
_this, get, getId, getObject, getObjectType, isSingleton
public 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.