public class BarrierSpec extends ConsumerEndpointSpec<BarrierSpec,BarrierMessageHandler>
adviceChain
componentsToRegister, endpointFactoryBean, handler
PARSER, target
logger
DEFAULT_PHASE
OBJECT_TYPE_ATTRIBUTE
修飾子 | コンストラクターと説明 |
---|---|
protected | BarrierSpec(long timeout) |
修飾子と型 | メソッドと説明 |
---|---|
BarrierSpec | async(boolean async) 非同期返信を許可します。 |
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, customizeMonoReply, handleMessageAdvice, notPropagatedHeaders, phase, poller, role, taskScheduler, transactional, transactional, transactional, transactional, transactional
assertHandler, getComponentsToRegister, id, obtainInputChannelFromFlow, obtainInputChannelFromFlow, poller, poller
_this, createInstance, destroyInstance, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stop
afterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingleton
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
public BarrierSpec outputProcessor(MessageGroupProcessor outputProcessor)
public BarrierSpec correlationStrategy(CorrelationStrategy correlationStrategy)
public BarrierSpec requiresReply(boolean requiresReply)
ConsumerEndpointSpec<BarrierSpec, BarrierMessageHandler>
の requiresReply
requiresReply
- requiresReply。AbstractReplyProducingMessageHandler.setRequiresReply(boolean)
public BarrierSpec sendTimeout(long sendTimeout)
ConsumerEndpointSpec<BarrierSpec, BarrierMessageHandler>
の sendTimeout
sendTimeout
- 送信タイムアウト。AbstractMessageProducingHandler.setSendTimeout(long)
public BarrierSpec order(int order)
ConsumerEndpointSpec<BarrierSpec, BarrierMessageHandler>
の order
order
- オーダー。MessageHandlerSupport.setOrder(int)
public BarrierSpec async(boolean async)
ConsumerEndpointSpec
org.springframework.util.concurrent.ListenableFuture
の場合、結果として future を送信するのではなく、満足したときに出力を送信します。ListenableFuture
以外のハンドラーの戻り値の型では無視されます。ConsumerEndpointSpec<BarrierSpec, BarrierMessageHandler>
の async
async
- 許可する場合は true。AbstractMessageProducingHandler.setAsync(boolean)
public reactor.util.function.Tuple2<ConsumerEndpointFactoryBean,BarrierMessageHandler> doGet()
ConsumerEndpointSpec<BarrierSpec, BarrierMessageHandler>
の doGet