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