S - ターゲット ConsumerEndpointSpec 実装型。H - ターゲット MessageHandler 実装型。public abstract class ConsumerEndpointSpec<S extends ConsumerEndpointSpec<S,H>,H extends MessageHandler> extends EndpointSpec<S,ConsumerEndpointFactoryBean,H>
EndpointSpec。| 修飾子と型 | フィールドと説明 |
|---|---|
protected ListSE<Advice> | adviceChain |
componentsToRegister, endpointFactoryBean, handlerPARSER, targetloggerDEFAULT_PHASEOBJECT_TYPE_ATTRIBUTE| 修飾子 | コンストラクターと説明 |
|---|---|
protected | ConsumerEndpointSpec(H messageHandler) |
| 修飾子と型 | メソッドと説明 |
|---|---|
S | advice(Advice... advice) ネストされた順序でエンドポイントのハンドラーに適用される Advice オブジェクトのリストを構成します。 |
S | async(boolean async) 非同期返信を許可します。 |
S | autoStartup(boolean autoStartup) |
S | customizeMonoReply(java.util.function.BiFunctionSE<Message<?>,reactor.core.publisher.Mono<?>,org.reactivestreams.Publisher<?>> replyCustomizer) |
protected reactor.util.function.Tuple2<ConsumerEndpointFactoryBean, H> | doGet() |
S | handleMessageAdvice(MethodInterceptor... interceptors) ネストされた順序でエンドポイントのハンドラーに適用される MethodInterceptor オブジェクトのリストを構成します。 |
S | notPropagatedHeaders(StringSE... headerPatterns) 受信メッセージからコピーされないヘッダーパターン("xxx*"、"*xxx"、"*xxx*"、または "xxx* yyy")を設定します。 |
S | order(int order) |
S | phase(int phase) |
S | poller(PollerMetadata pollerMetadata) |
S | requiresReply(boolean requiresReply) |
S | role(StringSE role) エンドポイントのロールを指定します。 |
S | sendTimeout(long sendTimeout) |
S | taskScheduler(TaskScheduler taskScheduler) ポーリングコンシューマーなどで、タスクをスケジュールするために TaskScheduler を構成します。 |
S | transactional()MessageHandler にはデフォルトの PlatformTransactionManager および DefaultTransactionAttribute を使用して TransactionInterceptor Advice を指定します。 |
S | transactional(boolean handleMessageAdvice)MessageHandler にはデフォルトの PlatformTransactionManager および DefaultTransactionAttribute を使用して TransactionInterceptor Advice を指定します。 |
S | transactional(TransactionInterceptor transactionInterceptor) |
S | transactional(TransactionManager transactionManager)TransactionInterceptor を指定します。Advice は、提供されている PlatformTransactionManager を使用し、MessageHandler にはデフォルトの DefaultTransactionAttribute を指定します。 |
S | transactional(TransactionManager transactionManager, boolean handleMessageAdvice)TransactionInterceptor を指定します。Advice は、提供されている PlatformTransactionManager を使用し、MessageHandler にはデフォルトの DefaultTransactionAttribute を指定します。 |
assertHandler, 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, waitSEprotected ConsumerEndpointSpec(H messageHandler)
public S phase(int phase)
EndpointSpec<S extends ConsumerEndpointSpec<S, H>,ConsumerEndpointFactoryBean, H extends MessageHandler> の phase phase - フェーズ。SmartLifecyclepublic S autoStartup(boolean autoStartup)
EndpointSpec<S extends ConsumerEndpointSpec<S, H>,ConsumerEndpointFactoryBean, H extends MessageHandler> の autoStartup autoStartup - autoStartup。SmartLifecyclepublic S poller(PollerMetadata pollerMetadata)
EndpointSpec<S extends ConsumerEndpointSpec<S, H>,ConsumerEndpointFactoryBean, H extends MessageHandler> の poller pollerMetadata - pollerMetadataAbstractPollingEndpointpublic S role(StringSE role)
EndpointSpecEndpointSpec<S extends ConsumerEndpointSpec<S, H>,ConsumerEndpointFactoryBean, H extends MessageHandler> の role role - このエンドポイントのロール。SmartLifecycle, SmartLifecycleRoleControllerpublic S taskScheduler(TaskScheduler taskScheduler)
TaskScheduler を構成します。デフォルトでは、グローバル ThreadPoolTaskScheduler Bean が使用されます。この構成は、たとえば、ポーリングタスク専用のスレッドを用意する必要がある場合に役立ちます。taskScheduler - 使用する TaskScheduler。IntegrationContextUtils.getTaskScheduler(org.springframework.beans.factory.BeanFactory)public S handleMessageAdvice(MethodInterceptor... interceptors)
MethodInterceptor オブジェクトのリストを構成します。アドバイスオブジェクトは handleMessage() メソッドに適用されるため、その後サブフロー全体に適用されます。interceptors - アドバイスチェーン。public S advice(Advice... advice)
Advice オブジェクトのリストを構成します。アドバイスオブジェクトはハンドラーにのみ適用されます。advice - アドバイスチェーン。public S transactional(TransactionManager transactionManager)
TransactionInterceptor を指定します。Advice は、提供されている PlatformTransactionManager を使用し、MessageHandler にはデフォルトの DefaultTransactionAttribute を指定します。transactionManager - 使用する TransactionManager。public S transactional(TransactionManager transactionManager, boolean handleMessageAdvice)
TransactionInterceptor を指定します。Advice は、提供されている PlatformTransactionManager を使用し、MessageHandler にはデフォルトの DefaultTransactionAttribute を指定します。transactionManager - 使用する TransactionManager。handleMessageAdvice - ターゲット Advice 型を示すフラグ: false - 通常の TransactionInterceptor; true - TransactionHandleMessageAdvice 拡張。public S transactional(TransactionInterceptor transactionInterceptor)
transactionInterceptor - 使用する TransactionInterceptor。TransactionInterceptorBuilderpublic S transactional()
MessageHandler にはデフォルトの PlatformTransactionManager および DefaultTransactionAttribute を使用して TransactionInterceptor Advice を指定します。public S transactional(boolean handleMessageAdvice)
MessageHandler にはデフォルトの PlatformTransactionManager および DefaultTransactionAttribute を使用して TransactionInterceptor Advice を指定します。handleMessageAdvice - ターゲット Advice 型を示すフラグ: false - 通常の TransactionInterceptor; true - TransactionHandleMessageAdvice 拡張。public S customizeMonoReply(java.util.function.BiFunctionSE<Message<?>,reactor.core.publisher.Mono<?>,org.reactivestreams.Publisher<?>> replyCustomizer)
replyCustomizer - BiFunctionSE は ReactiveRequestHandlerAdvice に伝播します。ReactiveRequestHandlerAdvicepublic S requiresReply(boolean requiresReply)
requiresReply - requiresReply。AbstractReplyProducingMessageHandler.setRequiresReply(boolean)public S sendTimeout(long sendTimeout)
sendTimeout - 送信タイムアウト。AbstractMessageProducingHandler.setSendTimeout(long)public S order(int order)
order - オーダー。MessageHandlerSupport.setOrder(int)public S async(boolean async)
org.springframework.util.concurrent.ListenableFuture の場合、結果として future を送信するのではなく、満足したときに出力を送信します。ListenableFuture 以外のハンドラーの戻り値の型では無視されます。async - 許可する場合は true。AbstractMessageProducingHandler.setAsync(boolean)public S notPropagatedHeaders(StringSE... headerPatterns)
headerPatterns - 受信メッセージから伝播しないヘッダー。AbstractMessageProducingHandler.setNotPropagatedHeaders(String...)protected reactor.util.function.Tuple2<ConsumerEndpointFactoryBean,H> doGet()
EndpointSpec<S extends ConsumerEndpointSpec<S, H>,ConsumerEndpointFactoryBean, H extends MessageHandler> の doGet