クラス DelayHandler

メソッドの詳細

• setMessageGroupId

  public void setMessageGroupId(StringSE messageGroupId)

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

  パラメーター:

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

  導入:

  6.2

• setDefaultDelay

  public void setDefaultDelay(long defaultDelay)

  デフォルトの遅延をミリ秒単位で設定します。delayExpression プロパティが指定されていない場合、デフォルトの遅延がすべてのメッセージに適用されます。評価結果が delayExpression のメッセージにのみ遅延を適用する必要がある場合は、この値を 0 に設定します。

  パラメーター:

  defaultDelay - ミリ秒単位のデフォルトの遅延。

• setDelayExpression

  public void setDelayExpression(Expression delayExpression)

  遅延期間（ミリ秒単位）または遅延する日付をチェックする必要がある Expression を指定します。このプロパティが設定されている場合、式の評価の結果（null でない場合）は、このハンドラーのデフォルトの遅延よりも優先されます。

  パラメーター:

  delayExpression - 遅延式。

• setDelayExpressionString

  public void setDelayExpressionString(StringSE delayExpression)

  遅延期間（ミリ秒単位）または遅延する日付をチェックする必要がある Expression を指定します。このプロパティが設定されている場合、式の評価の結果（null でない場合）は、このハンドラーのデフォルトの遅延よりも優先されます。

  パラメーター:

  delayExpression - 遅延式。

  導入:

  5.0

• setIgnoreExpressionFailures

  public void setIgnoreExpressionFailures(boolean ignoreExpressionFailures)

  delayExpression 評価によってスローされた Exceptions を無視するかどうか (ログに記録されるだけ) を指定します。この場合、遅延器は defaultDelay にフォールバックします。このプロパティが false として指定されている場合、delayExpression 評価 Exception は defaultDelay にフォールバックせずに呼び出し元にスローされます。デフォルトは true です。

  パラメーター:

  ignoreExpressionFailures - 式の評価の失敗を無視する必要がある場合は true。

  関連事項:

  • determineDelayForMessage(org.springframework.messaging.Message<?>)

• setMessageStore

  public void setMessageStore(MessageGroupStore messageStore)

  遅延を待機している間にメッセージを保管するために使用する必要がある MessageGroupStore を指定します。

  パラメーター:

  messageStore - メッセージストア。

• setDelayedAdviceChain

  public void setDelayedAdviceChain(ListSE<Advice> delayedAdviceChain)

  List<Advice> を指定して、DelayHandler.ReleaseMessageHandler プロキシに通知します。通常、トランザクションメッセージストアから取得した遅延メッセージにトランザクションを追加するために使用されます。

  パラメーター:

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

  関連事項:

  • createReleaseMessageTask()

• setDelayedMessageErrorChannel

  public void setDelayedMessageErrorChannel(MessageChannel delayedMessageErrorChannel)

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

  パラメーター:

  delayedMessageErrorChannel - チャンネル。

  導入:

  5.0.8

  関連事項:

  • setMaxAttempts(int)
  • setRetryDelay(long)

• setDelayedMessageErrorChannelName

  public void setDelayedMessageErrorChannelName(StringSE delayedMessageErrorChannelName)

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

  パラメーター:

  delayedMessageErrorChannelName - チャンネル名。

  導入:

  5.0.8

  関連事項:

  • setMaxAttempts(int)
  • setRetryDelay(long)

• setMaxAttempts

  public void setMaxAttempts(int maxAttempts)

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

  パラメーター:

  maxAttempts - 最大試行回数。

  導入:

  5.0.8

  関連事項:

  • setRetryDelay(long)

• setRetryDelay

  public void setRetryDelay(long retryDelay)

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

  パラメーター:

  retryDelay - 再試行遅延。

  導入:

  5.0.8

  関連事項:

  • setMaxAttempts(int)

• getComponentType

  public StringSE getComponentType()

  クラスからコピーされた説明: IntegrationObjectSupport

  サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。

  次で指定:

  インターフェース NamedComponent の getComponentType 

  オーバーライド:

  クラス MessageHandlerSupport の getComponentType 

• getIntegrationPatternType

  public IntegrationPatternType getIntegrationPatternType()

  インターフェースからコピーされた説明: IntegrationPattern

  このコンポーネントが実装するパターン型を返します。

  次で指定:

  インターフェース IntegrationPattern の getIntegrationPatternType 

  オーバーライド:

  クラス AbstractReplyProducingMessageHandler の getIntegrationPatternType 

  戻り値:

  このコンポーネントが実装する IntegrationPatternType

• doInit

  protected void doInit()

  オーバーライド:

  クラス AbstractReplyProducingMessageHandler の doInit 

• shouldCopyRequestHeaders

  protected boolean shouldCopyRequestHeaders()

  クラスからコピーされた説明: AbstractMessageProducingHandler

  サブクラスはこれをオーバーライドできます。デフォルトでは true。

  オーバーライド:

  クラス AbstractMessageProducingHandler の shouldCopyRequestHeaders 

  戻り値:

  リクエストヘッダーをコピーする必要がある場合は true。

• handleRequestMessage

  protected ObjectSE handleRequestMessage(Message<?> requestMessage)

  'requestMessage' が以前に遅延されていないかどうかを確認します（releaseMessageAfterDelay(org.springframework.messaging.Message<?>, long) および DelayHandler.DelayedMessageWrapper）。'requestMessage' （determineDelayForMessage(org.springframework.messaging.Message<?>)）の 'delay' を決定し、delay > 0 が 'delay' の後に 'releaseMessage' タスクをスケジュールするかどうかを決定するよりも。

  次で指定:

  クラス AbstractReplyProducingMessageHandler の handleRequestMessage 

  パラメーター:

  requestMessage - - 遅延する可能性のあるメッセージ。

  戻り値:

  -'requestMessage ' が遅延している場合は null、それ以外の場合 -'requestMessage' からの 'payload'。

  関連事項:

  • releaseMessage(org.springframework.messaging.Message<?>)

• rescheduleAt

  protected void rescheduleAt(Message<?> message, DateSE startTime)

• getDelayedMessageCount

  public int getDelayedMessageCount()

  次で指定:

  インターフェース DelayHandlerManagement の getDelayedMessageCount 

• reschedulePersistedMessages

  public void reschedulePersistedMessages()

  'messageStore' 内の永続化されたメッセージを読み取り、再スケジュールするために使用されます。アプリケーションの再起動時。ロジックは messageGroup.getMessages() での反復に基づいており、「遅延」ロジックのタスクをスケジュールします。この動作は、呼び出しスレッドのオーバーロードを回避することによって決定されます。

  次で指定:

  インターフェース DelayHandlerManagement の reschedulePersistedMessages 

• onApplicationEvent

  public void onApplicationEvent(ContextRefreshedEvent event)

  ContextRefreshedEvent を処理して、アプリケーションコンテキストの起動後できるだけ遅く reschedulePersistedMessages() を呼び出します。また、initialized をチェックして、「親子」コンテキストで公開される可能性のある他の ContextRefreshedEvent を無視します。Spring-MVC アプリケーションで。

  次で指定:

  インターフェース ApplicationListener<ContextRefreshedEvent> の onApplicationEvent 

  パラメーター:

  event - - アプリケーションコンテキストが完全に初期化された後に発生する ContextRefreshedEvent。

  関連事項:

  • reschedulePersistedMessages()