Class ScatterGatherSpec
java.lang.Object
org.springframework.integration.dsl.IntegrationComponentSpec<S,reactor.util.function.Tuple2<F,H>>
org.springframework.integration.dsl.EndpointSpec<S,ConsumerEndpointFactoryBean,H>
org.springframework.integration.dsl.ConsumerEndpointSpec<ScatterGatherSpec,ScatterGatherHandler>
org.springframework.integration.dsl.ScatterGatherSpec
- All Implemented Interfaces:
DisposableBean
,FactoryBean<reactor.util.function.Tuple2<ConsumerEndpointFactoryBean,
,ScatterGatherHandler>> InitializingBean
,Lifecycle
,Phased
,SmartLifecycle
,ComponentsRegistration
A
GenericEndpointSpec
extension for the ScatterGatherHandler
.- Since:
- 5.0
- Author:
- Artem Bilan, Gary Russell
- See Also:
-
Field Summary
Fields inherited from class org.springframework.integration.dsl.ConsumerEndpointSpec
adviceChain
Fields inherited from class org.springframework.integration.dsl.EndpointSpec
componentsToRegister, endpointFactoryBean, handler
Fields inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
logger, PARSER, target
Fields inherited from interface org.springframework.beans.factory.FactoryBean
OBJECT_TYPE_ATTRIBUTE
Fields inherited from interface org.springframework.context.SmartLifecycle
DEFAULT_PHASE
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionerrorChannel
(String errorChannel) Specify aMessageChannel
bean name for async error processing.gatherChannel
(MessageChannel gatherChannel) Specify aMessageChannel
(optional) which is used internally in theScatterGatherHandler
for gathering (aggregate) results for scattered requests.gatherTimeout
(long gatherTimeout) Specify a timeout (in milliseconds) for thePollableChannel.receive(long)
operation to wait for gathering results to output.Methods inherited from class org.springframework.integration.dsl.ConsumerEndpointSpec
advice, async, autoStartup, customizeMonoReply, doGet, handleMessageAdvice, notPropagatedHeaders, order, phase, poller, reactive, reactive, requiresReply, role, sendTimeout, taskScheduler, transactional, transactional, transactional, transactional, transactional
Methods inherited from class org.springframework.integration.dsl.EndpointSpec
assertHandler, getComponentsToRegister, id, obtainInputChannelFromFlow, obtainInputChannelFromFlow, poller, poller
Methods inherited from class org.springframework.integration.dsl.IntegrationComponentSpec
_this, afterPropertiesSet, destroy, get, getId, getObject, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.springframework.beans.factory.FactoryBean
isSingleton
-
Constructor Details
-
ScatterGatherSpec
-
-
Method Details
-
gatherChannel
Specify aMessageChannel
(optional) which is used internally in theScatterGatherHandler
for gathering (aggregate) results for scattered requests.- Parameters:
gatherChannel
- theMessageChannel
for gathering results.- Returns:
- the current
ScatterGatherSpec
instance.
-
gatherTimeout
Specify a timeout (in milliseconds) for thePollableChannel.receive(long)
operation to wait for gathering results to output. Defaults to30
seconds.- Parameters:
gatherTimeout
- thePollableChannel
receive timeout.- Returns:
- the current
ScatterGatherSpec
instance.
-
errorChannel
Specify aMessageChannel
bean name for async error processing. Defaults toIntegrationContextUtils.ERROR_CHANNEL_BEAN_NAME
.- Parameters:
errorChannel
- theMessageChannel
bean name for async error processing.- Returns:
- the current
ScatterGatherSpec
instance. - Since:
- 5.1.3
-