クラス ConsumerEndpointSpec<S extends ConsumerEndpointSpec<S,H>, H extends 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

• reactive

  public S reactive()

  コンシューマーエンドポイントを入力チャネルとは独立してリアクティブにします。

  戻り値:

  スペック

  導入:

  5.5

• reactive

  public S reactive(FunctionSE<? super reactor.core.publisher.Flux<Message<?>>, ? extends org.reactivestreams.Publisher<Message<?>>> reactiveCustomizer)

  コンシューマーエンドポイントを入力チャネルとは独立してリアクティブとして作成し、提供された関数を Flux.transform(Function) オペレーターに適用します。

  パラメーター:

  reactiveCustomizer - 入力チャネルの Flux を変換する関数。

  戻り値:

  スペック

  導入:

  5.5

• 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(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 <T,V> S customizeMonoReply(BiFunctionSE<Message<?>, reactor.core.publisher.Mono<T>, org.reactivestreams.Publisher<V>> replyCustomizer)

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

  型パラメーター:

  T - 受信応答ペイロード。

  V - 送信応答ペイロード。

  パラメーター:

  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)

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

  パラメーター:

  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