クラス DelayerEndpointSpec

方法の詳細

• defaultDelay

  public DelayerEndpointSpec defaultDelay(long defaultDelay)

  パラメーター:

  defaultDelay - defaultDelay。

  戻り値:

  エンドポイント仕様。

  関連事項:

  • DelayHandler.setDefaultDelay(long)

• ignoreExpressionFailures

  public DelayerEndpointSpec ignoreExpressionFailures(boolean ignoreExpressionFailures)

  パラメーター:

  ignoreExpressionFailures - ignoreExpressionFailures。

  戻り値:

  エンドポイント仕様。

  関連事項:

  • DelayHandler.setIgnoreExpressionFailures(boolean)

• messageStore

  public DelayerEndpointSpec messageStore(MessageGroupStore messageStore)

  パラメーター:

  messageStore - メッセージストア。

  戻り値:

  エンドポイント仕様。

• delayedAdvice

  public DelayerEndpointSpec delayedAdvice(Advice... advice)

  遅延メッセージが送信されたときにネストされた順序で適用される Advice オブジェクトのリストを構成します。

  パラメーター:

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

  戻り値:

  エンドポイント仕様。

• delayExpression

  public DelayerEndpointSpec delayExpression(StringSE delayExpression)

• delayExpression

  public DelayerEndpointSpec delayExpression(Expression delayExpression)

• delayedMessageErrorChannel

  public DelayerEndpointSpec delayedMessageErrorChannel(MessageChannel channel)

  リリースされたメッセージの送信に失敗した場合に ErrorMessage が送信されるメッセージチャネルを設定します。エラーフローが正常に戻った場合、リリースは完了です。エラーフローが例外をスローした場合、リリースは再試行されます。リリースタスクに関するトランザクションアドバイスがある場合、エラーフローはトランザクション内で呼び出されます。

  パラメーター:

  channel - チャンネル。

  戻り値:

  エンドポイント仕様。

  導入:

  5.0.8

  関連事項:

  • maxAttempts(int)
  • retryDelay(long)

• delayedMessageErrorChannel

  public DelayerEndpointSpec delayedMessageErrorChannel(StringSE channel)

  解放されたメッセージの送信に失敗した場合に ErrorMessage が送信されるメッセージチャネル名を設定します。エラーフローが正常に戻った場合、リリースは完了です。エラーフローが例外をスローした場合、リリースは再試行されます。リリースタスクに関するトランザクションアドバイスがある場合、エラーフローはトランザクション内で呼び出されます。

  パラメーター:

  channel - チャンネル名。

  戻り値:

  エンドポイント仕様。

  導入:

  5.0.8

  関連事項:

  • maxAttempts(int)
  • retryDelay(long)

• maxAttempts

  public DelayerEndpointSpec maxAttempts(int maxAttempts)

  メッセージのリリースが失敗した場合のリリースの最大試行回数を設定します。デフォルトの 5.

  パラメーター:

  maxAttempts - 最大試行回数。

  戻り値:

  エンドポイント仕様。

  導入:

  5.0.8

  関連事項:

  • retryDelay(long)

• retryDelay

  public DelayerEndpointSpec retryDelay(long retryDelay)

  リリースが失敗した後に再試行するときに適用する追加の遅延を設定します。デフォルトの 1000L。

  パラメーター:

  retryDelay - 再試行遅延。

  戻り値:

  エンドポイント仕様。

  導入:

  5.0.8

  関連事項:

  • maxAttempts(int)

• transactionalRelease

  public DelayerEndpointSpec transactionalRelease()

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

  戻り値:

  スペック。

  導入:

  5.0.8

• transactionalRelease

  public DelayerEndpointSpec transactionalRelease(TransactionInterceptor transactionInterceptor)

  MessageHandler に TransactionInterceptor Advice を指定します。

  パラメーター:

  transactionInterceptor - 使用する TransactionInterceptor。

  戻り値:

  スペック。

  導入:

  5.0.8

  関連事項:

  • TransactionInterceptorBuilder

• transactionalRelease

  public DelayerEndpointSpec transactionalRelease(TransactionManager transactionManager)

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

  パラメーター:

  transactionManager - 使用する TransactionManager。

  戻り値:

  スペック。

  導入:

  5.2.5

• delayFunction

  public <P> DelayerEndpointSpec delayFunction(FunctionSE<Message<P>, ObjectSE> delayFunction)

  Message に対する遅延値を決定する関数を指定します。通常、Java 8 ラムダ式で使用されます。

  
   .<Foo>delay("delayer", m -> m.getPayload().getDate(),
             c -> c.advice(this.delayedAdvice).messageStore(this.messageStore()))
  
  

  型パラメーター:

  P - ペイロード型。

  パラメーター:

  delayFunction - 遅延を決定するための FunctionSE。

  戻り値:

  エンドポイント仕様。

• messageGroupId

  public DelayerEndpointSpec messageGroupId(StringSE messageGroupId)

  このハンドラーで遅延メッセージを管理するためのグループ ID を設定します。必須。

  パラメーター:

  messageGroupId - 遅延メッセージのグループ ID。

  戻り値:

  エンドポイント仕様。

  導入:

  6.2

  関連事項:

  • DelayHandler.setMessageGroupId(String)

• taskScheduler

  public DelayerEndpointSpec taskScheduler(TaskScheduler taskScheduler)

  提供された TaskScheduler を DelayHandler に設定し、必要に応じて super を呼び出してこのハンドラーのエンドポイントに設定します。

  オーバーライド:

  クラス ConsumerEndpointSpec<DelayerEndpointSpec, DelayHandler> の taskScheduler 

  パラメーター:

  taskScheduler - 使用する TaskScheduler。

  戻り値:

  スペック

  関連事項:

  • IntegrationContextUtils.getTaskScheduler(BeanFactory)