public class BarrierSpec extends ConsumerEndpointSpec<BarrierSpec,BarrierMessageHandler>
adviceChaincomponentsToRegister, endpointFactoryBean, handlerPARSER, targetloggerDEFAULT_PHASEOBJECT_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, transactionalassertHandler, getComponentsToRegister, id, obtainInputChannelFromFlow, obtainInputChannelFromFlow, poller, poller_this, createInstance, destroyInstance, get, getId, getObjectType, getPhase, isAutoStartup, isRunning, start, stop, stopafterPropertiesSet, destroy, getBeanFactory, getBeanTypeConverter, getEarlySingletonInterfaces, getObject, isSingleton, setBeanClassLoader, setBeanFactory, setSingletoncloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEpublic 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)
ConsumerEndpointSpecorg.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