public class BarrierSpec extends ConsumerEndpointSpec<BarrierSpec,org.springframework.integration.aggregator.BarrierMessageHandler>
MessageHandlerSpec
for the BarrierMessageHandler
.adviceChain
componentToRegister, endpointFactoryBean, handler
logger, PARSER, target
Modifier and Type | Method and Description |
---|---|
BarrierSpec |
async(boolean async)
Allow async replies.
|
BarrierSpec |
correlationStrategy(org.springframework.integration.aggregator.CorrelationStrategy correlationStrategy) |
Tuple2<org.springframework.integration.config.ConsumerEndpointFactoryBean,org.springframework.integration.aggregator.BarrierMessageHandler> |
doGet() |
BarrierSpec |
order(int order) |
BarrierSpec |
outputProcessor(org.springframework.integration.aggregator.MessageGroupProcessor outputProcessor) |
BarrierSpec |
requiresReply(boolean requiresReply) |
BarrierSpec |
sendTimeout(long sendTimeout) |
advice, autoStartup, phase, poller, transactional, transactional, transactional, transactional, transactional
assertHandler, getComponentsToRegister, id, poller, poller
_this, get, getId, getObject, getObjectType, isSingleton
public BarrierSpec outputProcessor(org.springframework.integration.aggregator.MessageGroupProcessor outputProcessor)
public BarrierSpec correlationStrategy(org.springframework.integration.aggregator.CorrelationStrategy correlationStrategy)
public BarrierSpec requiresReply(boolean requiresReply)
requiresReply
in class ConsumerEndpointSpec<BarrierSpec,org.springframework.integration.aggregator.BarrierMessageHandler>
requiresReply
- the requiresReply.AbstractReplyProducingMessageHandler.setRequiresReply(boolean)
public BarrierSpec sendTimeout(long sendTimeout)
sendTimeout
in class ConsumerEndpointSpec<BarrierSpec,org.springframework.integration.aggregator.BarrierMessageHandler>
sendTimeout
- the send timeout.AbstractMessageProducingHandler.setSendTimeout(long)
public BarrierSpec order(int order)
order
in class ConsumerEndpointSpec<BarrierSpec,org.springframework.integration.aggregator.BarrierMessageHandler>
order
- the order.AbstractMessageHandler.setOrder(int)
public BarrierSpec async(boolean async)
ConsumerEndpointSpec
ListenableFuture
send
the output when it is satisfied rather than sending the future as the result.
Only subclasses that support this feature should set it.async
in class ConsumerEndpointSpec<BarrierSpec,org.springframework.integration.aggregator.BarrierMessageHandler>
async
- true to allow.AbstractMessageProducingHandler.setAsync(boolean)
public Tuple2<org.springframework.integration.config.ConsumerEndpointFactoryBean,org.springframework.integration.aggregator.BarrierMessageHandler> doGet()
doGet
in class EndpointSpec<BarrierSpec,org.springframework.integration.config.ConsumerEndpointFactoryBean,org.springframework.integration.aggregator.BarrierMessageHandler>