public class BarrierSpec extends ConsumerEndpointSpec<BarrierSpec,BarrierMessageHandler>
MessageHandlerSpec
for the BarrierMessageHandler
.adviceChain
componentsToRegister, endpointFactoryBean, handler
logger, PARSER, target
Modifier and Type | Method and Description |
---|---|
BarrierSpec |
async(boolean async)
Allow async replies.
|
BarrierSpec |
correlationStrategy(CorrelationStrategy correlationStrategy) |
reactor.util.function.Tuple2<ConsumerEndpointFactoryBean,BarrierMessageHandler> |
doGet() |
BarrierSpec |
order(int order) |
BarrierSpec |
outputProcessor(MessageGroupProcessor outputProcessor) |
BarrierSpec |
requiresReply(boolean requiresReply) |
BarrierSpec |
sendTimeout(long sendTimeout) |
advice, autoStartup, notPropagatedHeaders, phase, poller, role, taskScheduler, transactional, transactional, transactional, transactional, transactional
assertHandler, getComponentsToRegister, id, obtainInputChannelFromFlow, obtainInputChannelFromFlow, poller, poller
_this, afterPropertiesSet, destroy, get, getId, getObject, getObjectType
public BarrierSpec outputProcessor(MessageGroupProcessor outputProcessor)
public BarrierSpec correlationStrategy(CorrelationStrategy correlationStrategy)
public BarrierSpec requiresReply(boolean requiresReply)
requiresReply
in class ConsumerEndpointSpec<BarrierSpec,BarrierMessageHandler>
requiresReply
- the requiresReply.AbstractReplyProducingMessageHandler.setRequiresReply(boolean)
public BarrierSpec sendTimeout(long sendTimeout)
sendTimeout
in class ConsumerEndpointSpec<BarrierSpec,BarrierMessageHandler>
sendTimeout
- the send timeout.AbstractMessageProducingHandler.setSendTimeout(long)
public BarrierSpec order(int order)
order
in class ConsumerEndpointSpec<BarrierSpec,BarrierMessageHandler>
order
- the order.AbstractMessageHandler.setOrder(int)
public BarrierSpec async(boolean async)
ConsumerEndpointSpec
org.springframework.util.concurrent.ListenableFuture
, send the output when
it is satisfied rather than sending the future as the result. Ignored for handler
return types other than
ListenableFuture
.async
in class ConsumerEndpointSpec<BarrierSpec,BarrierMessageHandler>
async
- true to allow.AbstractMessageProducingHandler.setAsync(boolean)
public reactor.util.function.Tuple2<ConsumerEndpointFactoryBean,BarrierMessageHandler> doGet()
doGet
in class ConsumerEndpointSpec<BarrierSpec,BarrierMessageHandler>