クラス 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()

  次で指定:

  インターフェース 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 @Nullable 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() の反復処理に基づいており、'delay' ロジック用のタスクをスケジュールします。この動作は、呼び出しスレッドのオーバーロードを回避するために決定されます。

  次で指定:

  インターフェース DelayHandlerManagement 内の reschedulePersistedMessages 

• onApplicationEvent

  public void onApplicationEvent(ContextRefreshedEvent event)

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

  次で指定:

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

  パラメーター:

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

  関連事項:

  • reschedulePersistedMessages()