フィールドの詳細

• adviceChain

  protected final ListSE<Advice> adviceChain

コンストラクターの詳細

• ConsumerEndpointSpec

  protected ConsumerEndpointSpec(H messageHandler)

メソッドの詳細

• phase

  public S phase(int phase)

  次で指定:

  クラス EndpointSpec<S extends ConsumerEndpointSpec<S, H>,ConsumerEndpointFactoryBean, H extends MessageHandler> の phase 

  パラメーター:

  phase - フェーズ。

  戻り値:

  エンドポイント仕様。

  関連事項:

  SmartLifecycle

• autoStartup

  public S autoStartup(boolean autoStartup)

  次で指定:

  クラス EndpointSpec<S extends ConsumerEndpointSpec<S, H>,ConsumerEndpointFactoryBean, H extends MessageHandler> の autoStartup 

  パラメーター:

  autoStartup - autoStartup。

  戻り値:

  エンドポイント仕様

  関連事項:

  SmartLifecycle

• poller

  public S poller(PollerMetadata pollerMetadata)

  次で指定:

  クラス EndpointSpec<S extends ConsumerEndpointSpec<S, H>,ConsumerEndpointFactoryBean, H extends MessageHandler> の poller 

  パラメーター:

  pollerMetadata - pollerMetadata

  戻り値:

  エンドポイント仕様。

  関連事項:

  AbstractPollingEndpoint

• role

  public S role(StringSE role)

  クラスからコピーされた説明: EndpointSpec
  エンドポイントのロールを指定します。このようなエンドポイントは、グループとして開始 / 停止できます。

  次で指定:

  クラス EndpointSpec<S extends ConsumerEndpointSpec<S, H>,ConsumerEndpointFactoryBean, H extends MessageHandler> の role 

  パラメーター:

  role - このエンドポイントのロール。

  戻り値:

  エンドポイント仕様

  関連事項:

  SmartLifecycle, SmartLifecycleRoleController

• taskScheduler

  public S taskScheduler(TaskScheduler taskScheduler)

  ポーリングコンシューマーなどで、タスクをスケジュールするために TaskScheduler を構成します。デフォルトでは、グローバル ThreadPoolTaskScheduler Bean が使用されます。この構成は、たとえば、ポーリングタスク専用のスレッドを用意する必要がある場合に役立ちます。

  パラメーター:

  taskScheduler - 使用する TaskScheduler。

  戻り値:

  エンドポイント仕様。

  関連事項:

  IntegrationContextUtils.getTaskScheduler(org.springframework.beans.factory.BeanFactory)

• handleMessageAdvice

  public S handleMessageAdvice(MethodInterceptor... interceptors)

  ネストされた順序でエンドポイントのハンドラーに適用される MethodInterceptor オブジェクトのリストを構成します。アドバイスオブジェクトは handleMessage() メソッドに適用されるため、その後サブフロー全体に適用されます。

  パラメーター:

  interceptors - アドバイスチェーン。

  戻り値:

  エンドポイント仕様。

  導入:

  5.3

• advice

  public S advice(Advice... advice)

  ネストされた順序でエンドポイントのハンドラーに適用される Advice オブジェクトのリストを構成します。アドバイスオブジェクトはハンドラーにのみ適用されます。

  パラメーター:

  advice - アドバイスチェーン。

  戻り値:

  エンドポイント仕様。

• transactional

  public S transactional(TransactionManager transactionManager)

  TransactionInterceptor を指定します。Advice は、提供されている PlatformTransactionManager を使用し、MessageHandler にはデフォルトの DefaultTransactionAttribute を指定します。

  パラメーター:

  transactionManager - 使用する TransactionManager。

  戻り値:

  スペック。

• transactional

  public S transactional(TransactionManager transactionManager,
                         boolean handleMessageAdvice)

  TransactionInterceptor を指定します。Advice は、提供されている PlatformTransactionManager を使用し、MessageHandler にはデフォルトの DefaultTransactionAttribute を指定します。

  パラメーター:

  transactionManager - 使用する TransactionManager。

  handleMessageAdvice - ターゲット Advice 型を示すフラグ: false - 通常の TransactionInterceptor; true - TransactionHandleMessageAdvice 拡張。

  戻り値:

  スペック。

• transactional

  public S transactional(TransactionInterceptor transactionInterceptor)

  MessageHandler に TransactionInterceptor Advice を指定します。

  パラメーター:

  transactionInterceptor - 使用する TransactionInterceptor。

  戻り値:

  スペック。

  関連事項:

  TransactionInterceptorBuilder

• transactional

  public S transactional()

  MessageHandler にはデフォルトの PlatformTransactionManager および DefaultTransactionAttribute を使用して TransactionInterceptor Advice を指定します。

  戻り値:

  スペック。

• transactional

  public S transactional(boolean handleMessageAdvice)

  MessageHandler にはデフォルトの PlatformTransactionManager および DefaultTransactionAttribute を使用して TransactionInterceptor Advice を指定します。

  パラメーター:

  handleMessageAdvice - ターゲット Advice 型を示すフラグ: false - 通常の TransactionInterceptor; true - TransactionHandleMessageAdvice 拡張。

  戻り値:

  スペック。

• customizeMonoReply

  public S customizeMonoReply(java.util.function.BiFunctionSE<Message<?>,reactor.core.publisher.Mono<?>,org.reactivestreams.Publisher<?>> replyCustomizer)

  ReactiveRequestHandlerAdvice を介して Mono 応答をカスタマイズするための BiFunctionSE を指定します。

  パラメーター:

  replyCustomizer - BiFunctionSE は ReactiveRequestHandlerAdvice に伝播します。

  戻り値:

  スペック。

  導入:

  5.3

  関連事項:

  ReactiveRequestHandlerAdvice

• requiresReply

  public S requiresReply(boolean requiresReply)

  パラメーター:

  requiresReply - requiresReply。

  戻り値:

  エンドポイント仕様。

  関連事項:

  AbstractReplyProducingMessageHandler.setRequiresReply(boolean)

• sendTimeout

  public S sendTimeout(long sendTimeout)

  パラメーター:

  sendTimeout - 送信タイムアウト。

  戻り値:

  エンドポイント仕様。

  関連事項:

  AbstractMessageProducingHandler.setSendTimeout(long)

• order

  public S order(int order)

  パラメーター:

  order - オーダー。

  戻り値:

  エンドポイント仕様。

  関連事項:

  MessageHandlerSupport.setOrder(int)

• async

  public S async(boolean async)

  非同期応答を許可します。ハンドラーの応答が org.springframework.util.concurrent.ListenableFuture の場合、結果として future を送信するのではなく、満足したときに出力を送信します。ListenableFuture 以外のハンドラーの戻り値の型では無視されます。

  パラメーター:

  async - 許可する場合は true。

  戻り値:

  エンドポイント仕様。

  関連事項:

  AbstractMessageProducingHandler.setAsync(boolean)

• notPropagatedHeaders

  public S notPropagatedHeaders(StringSE... headerPatterns)

  受信メッセージからコピーされないヘッダーパターン（"xxx*"、"*xxx"、"*xxx*"、または "xxx* yyy"）を設定します。"*" としての少なくとも 1 つのパターンは、ヘッダーをまったくコピーしないことを意味します。

  パラメーター:

  headerPatterns - 受信メッセージから伝播しないヘッダー。

  戻り値:

  エンドポイント仕様。

  関連事項:

  AbstractMessageProducingHandler.setNotPropagatedHeaders(String...)

• doGet

  protected reactor.util.function.Tuple2<ConsumerEndpointFactoryBean,H> doGet()

  オーバーライド:

  クラス EndpointSpec<S extends ConsumerEndpointSpec<S, H>,ConsumerEndpointFactoryBean, H extends MessageHandler> の doGet