パッケージ org.springframework.integration.mqtt.outbound

クラス 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、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 実装。
導入:
5.5.5
作成者:
Artem Bilan, Lucas Bowler, Artem Vozhdayenko

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

    • 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)

    • setAsync

      public void setAsync(boolean async)
      メッセージを送信するときにブロックしない場合は、true に設定します。デフォルトは false。true の場合、メッセージ送信 / 配信イベントは、適切に構成された "ApplicationListener" またはイベント inbound-channel-adapter による受信のために公開されます。
      パラメーター:
      async - 非同期の場合は true。
      関連事項:

    • setAsyncEvents

      public void setAsyncEvents(boolean asyncEvents)
      setAsync(boolean) が true の場合、これを true に設定すると、MqttMessageSentEvent および MqttMessageDeliveredEvent の発行が発行されます。デフォルトは false。
      パラメーター:
      asyncEvents - asyncEvents。

    • 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