クラス DefaultHeaderChannelRegistry

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.channel.DefaultHeaderChannelRegistry
実装されたすべてのインターフェース:
RunnableSE、Aware、BeanFactoryAware、BeanNameAware、InitializingBean、ApplicationContextAware、Lifecycle、ComponentSourceAware、ExpressionCapable、HeaderChannelRegistry、NamedComponent、ManageableLifecycle
public class DefaultHeaderChannelRegistry extends IntegrationObjectSupport implements HeaderChannelRegistry, ManageableLifecycle, RunnableSE
チャネルを名前に変換し、名前でキー付けされたチャネルへの参照を保持します。フローがある時点でメッセージを直列化した場合に、ダウンストリーム BeanFactoryChannelResolver がチャネルを名前で検索できるようにします。チャネルは、構成可能な遅延（デフォルトでは 60 秒）後に期限切れになります。実際の平均有効期限は、1.5x の遅延になります。
導入:
3.0
作成者:
Gary Russell, Artem Bilan, Trung Pham, Christian Tzolov

  • フィールドの詳細

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

    • DefaultHeaderChannelRegistry

      public DefaultHeaderChannelRegistry()
      チャネルの有効期限のデフォルトの遅延でレジストリを構築します。

    • DefaultHeaderChannelRegistry

      public DefaultHeaderChannelRegistry(long reaperDelay)
      チャネルの有効期限が切れるまでの指定された遅延 (ミリ秒) でレジストリを構築します。
      パラメーター:
      reaperDelay - ミリ秒単位の遅延。

  • メソッドの詳細

    • setReaperDelay

      public final void setReaperDelay(long reaperDelay)
      リーパー遅延を設定します。
      パラメーター:
      reaperDelay - ミリ秒単位の遅延。

    • getReaperDelay

      public final long getReaperDelay()

    • setRemoveOnGet

      public void setRemoveOnGet(boolean removeOnGet)
      channelNameToChannel(String) が呼び出されたときにチャネルマッピングをすぐに削除するには、true に設定します。
      パラメーター:
      removeOnGet - すぐに削除する場合は true、デフォルトは false。
      導入:
      4.1

    • size

      public final int size()
      次で指定:
      インターフェース HeaderChannelRegistry の size 
      戻り値:
      レジストリの現在のサイズ

    • onInit

      protected void onInit()
      クラスからコピーされた説明: IntegrationObjectSupport
      サブクラスは、初期化ロジック用にこれを実装できます。
      オーバーライド:
      クラス IntegrationObjectSupport の onInit 

    • start

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

    • stop

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

    • stop

      public void stop(RunnableSE callback)

    • isRunning

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

    • channelToChannelName

      @Nullable public ObjectSE channelToChannelName(@Nullable ObjectSE channel)
      インターフェースからコピーされた説明: HeaderChannelRegistry
      チャネルを名前（文字列）に変換します。チャネルが MessageChannel でない場合、変更されずに返されます。
      次で指定:
      インターフェース HeaderChannelRegistry の channelToChannelName 
      パラメーター:
      channel - チャンネル。
      戻り値:
      チャネル名、または MessageChannel でない場合はチャネル。

    • channelToChannelName

      @Nullable public ObjectSE channelToChannelName(@Nullable ObjectSE channel, long timeToLive)
      インターフェースからコピーされた説明: HeaderChannelRegistry
      チャネルを名前（文字列）に変換します。チャネルが MessageChannel でない場合、変更されずに返されます。
      次で指定:
      インターフェース HeaderChannelRegistry の channelToChannelName 
      パラメーター:
      channel - チャンネル。
      timeToLive - 最低でも（ms）の時間、チャネルマッピングはレジストリに残る必要があります。
      戻り値:
      チャネル名、または MessageChannel でない場合はチャネル。

    • channelNameToChannel

      @Nullable public MessageChannel channelNameToChannel(@Nullable StringSE name)
      インターフェースからコピーされた説明: HeaderChannelRegistry
      チャネル名を MessageChannel に変換します（登録されている場合）。
      次で指定:
      インターフェース HeaderChannelRegistry の channelNameToChannel 
      パラメーター:
      name - チャネルの名前。
      戻り値:
      チャネル。名前で登録されたチャネルがない場合は null。

    • runReaper

      public void runReaper()
      スケジュールされたリープタスクをキャンセルして、すぐに実行します。その後、再スケジュールします。
      次で指定:
      インターフェース HeaderChannelRegistry の runReaper 

    • run

      public void run()
      次で指定:
      インターフェース RunnableSE の run