クラス Mqttv5PahoMessageHandler

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.MessageHandlerSupport
org.springframework.integration.handler.AbstractMessageHandler
org.springframework.integration.mqtt.outbound.AbstractMqttMessageHandler<org.eclipse.paho.mqttv5.client.IMqttAsyncClient, org.eclipse.paho.mqttv5.client.MqttConnectionOptions>
org.springframework.integration.mqtt.outbound.Mqttv5PahoMessageHandler
実装済みのインターフェース一覧:
org.eclipse.paho.mqttv5.client.MqttCallback, org.reactivestreams.Subscriber<Message<?>>, Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, ApplicationEventPublisherAware, Lifecycle, Ordered, ComponentSourceAware, ExpressionCapable, Orderable, IntegrationPattern, MqttComponent<org.eclipse.paho.mqttv5.client.MqttConnectionOptions>, NamedComponent, IntegrationManagement, ManageableLifecycle, TrackableComponent, MessageHandler, reactor.core.CoreSubscriber<Message<?>>
public class Mqttv5PahoMessageHandler extends AbstractMqttMessageHandler<org.eclipse.paho.mqttv5.client.IMqttAsyncClient, org.eclipse.paho.mqttv5.client.MqttConnectionOptions> implements org.eclipse.paho.mqttv5.client.MqttCallback, MqttComponent<org.eclipse.paho.mqttv5.client.MqttConnectionOptions>
MQTTv5 の AbstractMqttMessageHandler 実装。

byte[] または StringSE 以外のペイロードは、設定済みの MessageConverter を使用します。

導入:
5.5.5
作成者:
Artem Bilan, Lucas Bowler, Artem Vozhdayenko, Glenn Renfro, Deng Pan

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

    • Mqttv5PahoMessageHandler

      public Mqttv5PahoMessageHandler(StringSE url, StringSE clientId)

    • Mqttv5PahoMessageHandler

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

    • Mqttv5PahoMessageHandler

      public Mqttv5PahoMessageHandler(ClientManager<org.eclipse.paho.mqttv5.client.IMqttAsyncClient, org.eclipse.paho.mqttv5.client.MqttConnectionOptions> clientManager)
      単一の ClientManager を使用する必要がある場合 (たとえば、MQTT 接続を再利用する場合) に、このコンストラクターを使用します。
      パラメーター:
      clientManager - クライアントマネージャー。
      導入:
      6.0

  • 方法の詳細

    • getConnectionInfo

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

    • setPersistence

      public void setPersistence(@Nullable org.eclipse.paho.mqttv5.client.MqttClientPersistence persistence)

    • setHeaderMapper

      public void setHeaderMapper(HeaderMapper<org.eclipse.paho.mqttv5.common.packet.MqttProperties> headerMapper)

    • onInit

      protected void onInit()
      クラスからコピーされた説明: IntegrationObjectSupport
      サブクラスは、初期化ロジック用にこれを実装できます。
      オーバーライド:
      クラス AbstractMqttMessageHandler<org.eclipse.paho.mqttv5.client.IMqttAsyncClient, org.eclipse.paho.mqttv5.client.MqttConnectionOptions> の onInit 

    • doStart

      protected void doStart()
      次で指定:
      クラス AbstractMqttMessageHandler<org.eclipse.paho.mqttv5.client.IMqttAsyncClient, org.eclipse.paho.mqttv5.client.MqttConnectionOptions> の doStart 

    • doStop

      protected void doStop()
      次で指定:
      クラス AbstractMqttMessageHandler<org.eclipse.paho.mqttv5.client.IMqttAsyncClient, org.eclipse.paho.mqttv5.client.MqttConnectionOptions> の doStop 

    • destroy

      public void destroy()
      次で指定:
      インターフェース DisposableBean 内の destroy 
      次で指定:
      インターフェース IntegrationManagement 内の destroy 
      オーバーライド:
      クラス MessageHandlerSupport の destroy 

    • handleMessageInternal

      protected void handleMessageInternal(Message<?> message)
      オーバーライド:
      クラス AbstractMqttMessageHandler<org.eclipse.paho.mqttv5.client.IMqttAsyncClient, org.eclipse.paho.mqttv5.client.MqttConnectionOptions> の handleMessageInternal 

    • publish

      protected void publish(StringSE topic, ObjectSE mqttMessage, Message<?> message)
      次で指定:
      クラス AbstractMqttMessageHandler<org.eclipse.paho.mqttv5.client.IMqttAsyncClient, org.eclipse.paho.mqttv5.client.MqttConnectionOptions> の publish 

    • deliveryComplete

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

    • 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 

    • messageArrived

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

    • 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