クラス PollerSpec

メソッドの詳細

• transactionSynchronizationFactory

  public PollerSpec transactionSynchronizationFactory(TransactionSynchronizationFactory transactionSynchronizationFactory)

  TransactionSynchronizationFactory を指定して、poll 操作の前後のトランザクションに TransactionSynchronization をアタッチします。

  パラメーター:

  transactionSynchronizationFactory - 使用する TransactionSynchronizationFactory。

  戻り値:

  スペック。

• errorHandler

  public PollerSpec errorHandler(ErrorHandler errorHandler)

  ErrorHandler を指定して、taskExecutor を ErrorHandlingTaskExecutor にラップします。

  パラメーター:

  errorHandler - 使用する ErrorHandler。

  戻り値:

  スペック。

  関連事項:

  • taskExecutor(Executor)

• errorChannel

  public PollerSpec errorChannel(MessageChannel errorChannel)

  ポーリングが失敗した場合にエラーメッセージを送信するために使用する MessageChannel を指定します。

  パラメーター:

  errorChannel - 使用する MessageChannel。

  戻り値:

  スペック。

  関連事項:

  • MessagePublishingErrorHandler

• errorChannel

  public PollerSpec errorChannel(StringSE errorChannelName)

  ポーリングが失敗した場合にエラーメッセージを送信するために使用する MessageChannel の Bean 名を指定します。

  パラメーター:

  errorChannelName - 使用する MessageChannel の Bean 名。

  戻り値:

  スペック。

  関連事項:

  • MessagePublishingErrorHandler

• maxMessagesPerPoll

  public PollerSpec maxMessagesPerPoll(long maxMessagesPerPoll)

  パラメーター:

  maxMessagesPerPoll - maxMessagesPerPoll を設定します。

  戻り値:

  スペック。

  関連事項:

  • PollerMetadata.setMaxMessagesPerPoll(long)

• receiveTimeout

  public PollerSpec receiveTimeout(long receiveTimeout)

  MessageChannel でメッセージを待機するタイムアウトをミリ秒単位で指定します。デフォルトは 1000 です。

  パラメーター:

  receiveTimeout - 使用するタイムアウト。

  戻り値:

  スペック。

  関連事項:

  • PollableChannel.receive(long)

• advice

  public PollerSpec advice(Advice... advice)

  pollingTask に AOP Advice を指定します。

  パラメーター:

  advice - 使用する Advice。

  戻り値:

  スペック。

• transactional

  public PollerSpec transactional(TransactionManager transactionManager)

  TransactionInterceptor Advice を、付属の PlatformTransactionManager で指定し、pollingTask のデフォルトの DefaultTransactionAttribute を指定します。

  パラメーター:

  transactionManager - 使用する TransactionManager。

  戻り値:

  スペック。

• transactional

  public PollerSpec transactional()

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

  戻り値:

  スペック。

• transactional

  public PollerSpec transactional(TransactionInterceptor transactionInterceptor)

  pollingTask に TransactionInterceptor Advice を指定します。

  パラメーター:

  transactionInterceptor - 使用する TransactionInterceptor。

  戻り値:

  スペック。

  関連事項:

  • TransactionInterceptorBuilder

• taskExecutor

  public PollerSpec taskExecutor(ExecutorSE taskExecutor)

  pollingTask を実行するには、ExecutorSE を指定します。

  パラメーター:

  taskExecutor - 使用する ExecutorSE。

  戻り値:

  スペック。

• getComponentsToRegister

  public MapSE<ObjectSE,StringSE> getComponentsToRegister()

  次で指定:

  インターフェース ComponentsRegistration の getComponentsToRegister