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

クラス MessageGroupStoreReaper

java.lang.ObjectSE
org.springframework.integration.store.MessageGroupStoreReaper
実装済みのインターフェース一覧:
RunnableSE、DisposableBean、InitializingBean、Lifecycle、Phased、SmartLifecycle
public class MessageGroupStoreReaper extends ObjectSE implements RunnableSE, DisposableBean, InitializingBean, SmartLifecycle
MessageGroupStore 内の MessageGroup インスタンスの明示的な時間指定有効期限を許可する便利な構成可能コンポーネント。このコンポーネントは、リモートまたは時限実行に役立つ引数なしの run() メソッドと、シャットダウン時にオプションで呼び出すことができる destroy() メソッドを提供します。
作成者:
Dave Syer, Dave Turanski, Artem Bilan

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

    • MessageGroupStoreReaper

      public MessageGroupStoreReaper(MessageGroupStore messageGroupStore)

    • MessageGroupStoreReaper

      public MessageGroupStoreReaper()

  • 方法の詳細

    • setExpireOnDestroy

      public void setExpireOnDestroy(boolean expireOnDestroy)
      このコンポーネントが破棄されたとき（つまり、通常、それを囲む ApplicationContext が閉じられたとき）にストアを期限切れにする必要があることを示すフラグ。
      パラメーター:
      expireOnDestroy - 設定するフラグ値

    • setTimeout

      public void setTimeout(long timeout)
      ミリ秒単位のタイムアウト（デフォルトは -1）。負の場合、タイムアウトするグループはありません。ゼロより大きい場合、このコンポーネントが run() の場合、その値より古いすべてのグループが期限切れになります。
      パラメーター:
      timeout - 設定するタイムアウト

    • setMessageGroupStore

      public void setMessageGroupStore(MessageGroupStore messageGroupStore)
      他の構成に従って期限切れになるメッセージグループストア。
      パラメーター:
      messageGroupStore - 設定する MessageGroupStore

    • afterPropertiesSet

      public void afterPropertiesSet()
      次で指定:
      インターフェース InitializingBean 内の afterPropertiesSet 

    • destroy

      public void destroy()
      次で指定:
      インターフェース DisposableBean 内の destroy 

    • run

      public void run()
      提供された timeout より古いメッセージグループをすべて期限切れにします。通常、このメソッドはスケジュールされたタスクによって実行されます。
      次で指定:
      インターフェース RunnableSE 内の run 

    • start

      public final void start()
      次で指定:
      インターフェース Lifecycle 内の start 

    • stop

      public void stop()
      次で指定:
      インターフェース Lifecycle 内の stop 

    • isRunning

      public final boolean isRunning()
      次で指定:
      インターフェース Lifecycle 内の isRunning 

    • getPhase

      public int getPhase()
      次で指定:
      インターフェース Phased 内の getPhase 
      次で指定:
      インターフェース SmartLifecycle 内の getPhase 

    • setPhase

      public void setPhase(int phase)

    • isAutoStartup

      public boolean isAutoStartup()
      次で指定:
      インターフェース SmartLifecycle 内の isAutoStartup 

    • setAutoStartup

      public void setAutoStartup(boolean autoStartup)