パッケージ org.springframework.integration.dsl

クラス DelayerEndpointSpec

java.lang.ObjectSE
org.springframework.integration.dsl.IntegrationComponentSpec <S、reactor.util.function.Tuple2<F、H>>
org.springframework.integration.dsl.EndpointSpec<S,ConsumerEndpointFactoryBean,H>
org.springframework.integration.dsl.ConsumerEndpointSpec<DelayerEndpointSpec,DelayHandler>
org.springframework.integration.dsl.DelayerEndpointSpec
実装されたすべてのインターフェース:
DisposableBean、FactoryBean<reactor.util.function.Tuple2<ConsumerEndpointFactoryBean,DelayHandler>>、InitializingBean、Lifecycle、Phased、SmartLifecycle、ComponentsRegistration
public class DelayerEndpointSpec extends ConsumerEndpointSpec<DelayerEndpointSpec,DelayHandler>
DelayHandler の ConsumerEndpointSpec。messageGroupId(String) は必須オプションです。
導入:
5.0
作成者:
Artem Bilan, Gary Russell
関連事項:

  • コンストラクターの詳細

    • DelayerEndpointSpec

      protected DelayerEndpointSpec()

    • DelayerEndpointSpec

      protected DelayerEndpointSpec(DelayHandler delayHandler)

  • メソッドの詳細

    • defaultDelay

      public DelayerEndpointSpec defaultDelay(long defaultDelay)
      パラメーター:
      defaultDelay - defaultDelay。
      戻り値:
      エンドポイント仕様。
      関連事項:

    • ignoreExpressionFailures

      public DelayerEndpointSpec ignoreExpressionFailures(boolean ignoreExpressionFailures)
      パラメーター:
      ignoreExpressionFailures - ignoreExpressionFailures。
      戻り値:
      エンドポイント仕様。
      関連事項:

    • 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
      関連事項:

    • delayedMessageErrorChannel

      public DelayerEndpointSpec delayedMessageErrorChannel(StringSE channel)
      解放されたメッセージの送信に失敗した場合に ErrorMessage が送信されるメッセージチャネル名を設定します。エラーフローが正常に戻った場合、リリースは完了です。エラーフローが例外をスローした場合、リリースは再試行されます。リリースタスクに関するトランザクションアドバイスがある場合、エラーフローはトランザクション内で呼び出されます。
      パラメーター:
      channel - チャンネル名。
      戻り値:
      エンドポイント仕様。
      導入:
      5.0.8
      関連事項:

    • maxAttempts

      public DelayerEndpointSpec maxAttempts(int maxAttempts)
      メッセージのリリースが失敗した場合のリリースの最大試行回数を設定します。デフォルトの 5.
      パラメーター:
      maxAttempts - 最大試行回数。
      戻り値:
      エンドポイント仕様。
      導入:
      5.0.8
      関連事項:

    • retryDelay

      public DelayerEndpointSpec retryDelay(long retryDelay)
      リリースが失敗した後に再試行するときに適用する追加の遅延を設定します。デフォルトの 1000L。
      パラメーター:
      retryDelay - 再試行遅延。
      戻り値:
      エンドポイント仕様。
      導入:
      5.0.8
      関連事項:

    • 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
      関連事項:

    • 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
      関連事項: