クラス Mqttv5ClientManager

java.lang.ObjectSE
org.springframework.integration.mqtt.core.AbstractMqttClientManager<org.eclipse.paho.mqttv5.client.IMqttAsyncClient, org.eclipse.paho.mqttv5.client.MqttConnectionOptions>
org.springframework.integration.mqtt.core.Mqttv5ClientManager
実装済みのインターフェース一覧:
org.eclipse.paho.mqttv5.client.MqttCallback, Aware, BeanNameAware, ApplicationEventPublisherAware, Lifecycle, Phased, SmartLifecycle, ClientManager<org.eclipse.paho.mqttv5.client.IMqttAsyncClient, org.eclipse.paho.mqttv5.client.MqttConnectionOptions>, MqttComponent<org.eclipse.paho.mqttv5.client.MqttConnectionOptions>
public class Mqttv5ClientManager extends AbstractMqttClientManager<org.eclipse.paho.mqttv5.client.IMqttAsyncClient, org.eclipse.paho.mqttv5.client.MqttConnectionOptions> implements org.eclipse.paho.mqttv5.client.MqttCallback
MQTT v5 プロトコルのクライアントマネージャーの実装。クライアント ID とサーバー URI が必要です。必要に応じて、接続オプションをオーバーライドして、MqttConnectionOptions 依存関係として渡すことができます。デフォルトでは、自動再接続が使用されます。オフにする必要がある場合は、MqttConnectionFailedEvent をリッスンし、手動で MQTT クライアントに再接続する必要があります。
導入:
6.0
作成者:
Artem Vozhdayenko, Artem Bilan, Christian Tzolov, Jiri Soucek

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

    • Mqttv5ClientManager

      public Mqttv5ClientManager(StringSE url, StringSE clientId)

    • Mqttv5ClientManager

      public Mqttv5ClientManager(org.eclipse.paho.mqttv5.client.MqttConnectionOptions connectionOptions, StringSE clientId)

  • 方法の詳細

    • setPersistence

      public void setPersistence(org.eclipse.paho.mqttv5.client.MqttClientPersistence persistence)
      クライアントの MqttClientPersistence を設定します。
      パラメーター:
      persistence - クライアントに使用する永続化の実装

    • getConnectionInfo

      public org.eclipse.paho.mqttv5.client.MqttConnectionOptions getConnectionInfo()
      インターフェースからコピーされた説明: MqttComponent
      接続に関する情報を返します。
      次で指定:
      インターフェース MqttComponent<org.eclipse.paho.mqttv5.client.MqttConnectionOptions> 内の getConnectionInfo 
      戻り値:
      情報。

    • start

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

    • stop

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

    • messageArrived

      public void messageArrived(StringSE topic, org.eclipse.paho.mqttv5.common.MqttMessage message)
      次で指定:
      インターフェース org.eclipse.paho.mqttv5.client.MqttCallback 内の messageArrived 

    • deliveryComplete

      public void deliveryComplete(org.eclipse.paho.mqttv5.client.IMqttToken token)
      次で指定:
      インターフェース org.eclipse.paho.mqttv5.client.MqttCallback 内の deliveryComplete 

    • connectComplete

      public void connectComplete(boolean reconnect, StringSE serverURI)
      次で指定:
      インターフェース org.eclipse.paho.mqttv5.client.MqttCallback 内の connectComplete 

    • authPacketArrived

      public void authPacketArrived(int reasonCode, org.eclipse.paho.mqttv5.common.packet.MqttProperties properties)
      次で指定:
      インターフェース org.eclipse.paho.mqttv5.client.MqttCallback 内の authPacketArrived 

    • disconnected

      public void disconnected(org.eclipse.paho.mqttv5.client.MqttDisconnectResponse disconnectResponse)
      次で指定:
      インターフェース org.eclipse.paho.mqttv5.client.MqttCallback 内の disconnected 

    • mqttErrorOccurred

      public void mqttErrorOccurred(org.eclipse.paho.mqttv5.common.MqttException exception)
      次で指定:
      インターフェース org.eclipse.paho.mqttv5.client.MqttCallback 内の mqttErrorOccurred 

    • isConnected

      public boolean isConnected()
      インターフェースからコピーされた説明: ClientManager
      管理対象クライアント isConnected を返します。
      次で指定:
      インターフェース ClientManager<org.eclipse.paho.mqttv5.client.IMqttAsyncClient, org.eclipse.paho.mqttv5.client.MqttConnectionOptions> 内の isConnected 
      戻り値:
      管理対象クライアント isConnected。