クラス AbstractMqttClientManager<T,C>

java.lang.ObjectSE
org.springframework.integration.mqtt.core.AbstractMqttClientManager<T,C>
型パラメーター:
T - MQTT クライアント型
C - MQTT 接続オプション型 (v5 または v3)
実装されているすべてのインターフェース:
Aware、BeanNameAware、ApplicationEventPublisherAware、Lifecycle、Phased、SmartLifecycle、ClientManager<T,C>、MqttComponent<C>
既知の直属サブクラス
Mqttv3ClientManager, Mqttv5ClientManager
public abstract class AbstractMqttClientManager<T,C> extends ObjectSE implements ClientManager<T,C>, ApplicationEventPublisherAware
一般的な v3/v5 クライアントマネージャー実装のベースとなる MQTT クライアントマネージャーの抽象クラス。いくつかの基本的なユーティリティと実装に依存しないフィールドとメソッドが含まれています。
導入:
6.0
作成者:
Artem Vozhdayenko, Artem Bilan, Christian Tzolov

  • フィールドの詳細

    • logger

      protected final Log logger

    • lock

      protected final LockSE lock

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

    • AbstractMqttClientManager

      protected AbstractMqttClientManager(StringSE clientId)

  • メソッドの詳細

    • setManualAcks

      public void setManualAcks(boolean manualAcks)

    • getUrl

      protected StringSE getUrl()

    • setUrl

      protected void setUrl(StringSE url)

    • getClientId

      protected StringSE getClientId()

    • getApplicationEventPublisher

      protected ApplicationEventPublisher getApplicationEventPublisher()

    • setClient

      protected void setClient(T client)

    • getCallbacks

      protected SetSE<ClientManager.ConnectCallback> getCallbacks()

    • setCompletionTimeout

      public void setCompletionTimeout(long completionTimeout)
      操作の完了タイムアウトを設定します。デフォルトは 30000L < T、C > ミリ秒です。
      パラメーター:
      completionTimeout - タイムアウト。
      導入:
      6.0.3

    • getCompletionTimeout

      protected long getCompletionTimeout()

    • setDisconnectCompletionTimeout

      public void setDisconnectCompletionTimeout(long completionTimeout)
      切断時の完了タイムアウトを設定します。デフォルトは 5000L < T、C > ミリ秒です。
      パラメーター:
      completionTimeout - タイムアウト。
      導入:
      6.0.3

    • getDisconnectCompletionTimeout

      protected long getDisconnectCompletionTimeout()

    • isManualAcks

      public boolean isManualAcks()
      インターフェースからコピーされた説明: ClientManager
      手動確認を使用する必要がある場合。デフォルトでは false です。
      次で指定:
      インターフェース ClientManager<T,C> の isManualAcks 
      戻り値:
      手動確認を使用する必要がある場合は true。

    • getClient

      public T getClient()
      インターフェースからコピーされた説明: ClientManager
      管理対象クライアントを返します。
      次で指定:
      インターフェース ClientManager<T,C> の getClient 
      戻り値:
      管理対象クライアント。

    • setApplicationEventPublisher

      public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
      次で指定:
      インターフェース ApplicationEventPublisherAware の setApplicationEventPublisher 

    • setBeanName

      public void setBeanName(StringSE name)
      次で指定:
      インターフェース BeanNameAware の setBeanName 

    • getBeanName

      public StringSE getBeanName()
      インターフェースからコピーされた説明: MqttComponent
      このコンポーネントの Bean 名を返します。
      次で指定:
      インターフェース MqttComponent<T> の getBeanName 
      戻り値:
      Bean 名。

    • getPhase

      public int getPhase()
      SmartLifecycle でのコンポーネントの自動開始のフェーズ。カスタムが必要な場合は、正しい動作のために AbstractMqttMessageDrivenChannelAdapter 実装のフェーズよりも小さい必要があることに注意してください。デフォルトのフェーズは DEFAULT_MANAGER_PHASE です。
      次で指定:
      インターフェース Phased の getPhase 
      次で指定:
      インターフェース SmartLifecycle の getPhase 
      戻り値:
      SmartLifecycle 自動開始フェーズ
      関連事項:

    • addCallback

      public void addCallback(ClientManager.ConnectCallback connectCallback)
      インターフェースからコピーされた説明: ClientManager
      クライアントからの connectComplete イベントのコールバックを登録します。
      次で指定:
      インターフェース ClientManager<T,C> の addCallback 
      パラメーター:
      connectCallback - 登録する ClientManager.ConnectCallback。

    • removeCallback

      public boolean removeCallback(ClientManager.ConnectCallback connectCallback)
      インターフェースからコピーされた説明: ClientManager
      登録からコールバックを削除します。
      次で指定:
      インターフェース ClientManager<T,C> の removeCallback 
      パラメーター:
      connectCallback - 登録解除する ClientManager.ConnectCallback。
      戻り値:
      コールバックが削除された場合は true。

    • isRunning

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

    • setPhase

      public void setPhase(int phase)
      コンポーネントの自動起動のフェーズを SmartLifecycle に設定します。カスタムが必要な場合は、正しい動作のために AbstractMqttMessageDrivenChannelAdapter 実装のフェーズよりも小さい必要があることに注意してください。
      関連事項: