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

クラス MqttPahoMessageHandler

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.client.mqttv3.IMqttAsyncClient,org.eclipse.paho.client.mqttv3.MqttConnectOptions>
org.springframework.integration.mqtt.outbound.MqttPahoMessageHandler
実装されたすべてのインターフェース:
org.eclipse.paho.client.mqttv3.MqttCallback、org.reactivestreams.Subscriber<Message<?>>、Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、ApplicationContextAware、ApplicationEventPublisherAware、Lifecycle、Ordered、ExpressionCapable、Orderable、IntegrationPattern、MqttComponent<org.eclipse.paho.client.mqttv3.MqttConnectOptions>、MqttPahoComponent、NamedComponent、IntegrationManagement、ManageableLifecycle、TrackableComponent、MessageHandler、reactor.core.CoreSubscriber<Message<?>>
public class MqttPahoMessageHandler extends AbstractMqttMessageHandler<org.eclipse.paho.client.mqttv3.IMqttAsyncClient,org.eclipse.paho.client.mqttv3.MqttConnectOptions> implements org.eclipse.paho.client.mqttv3.MqttCallback, MqttPahoComponent
Eclipse Paho の実装。このコンポーネントによって公開された MqttIntegrationEvent を使用する場合は、MqttPahoComponent handler = event.getSourceAsType() を使用して参照を取得し、Bean 名と MqttConnectOptions を取得できるようにします。この手法により、同じイベントリスナー内の受信エンドポイントと送信エンドポイントの両方からのイベントを利用できます。
導入:
4.0
作成者:
Gary Russell, Artem Bilan, Artem Vozhdayenko, Christian Tzolov

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

    • MqttPahoMessageHandler

      public MqttPahoMessageHandler(StringSE url, StringSE clientId)
      追加の MqttConnectOptions が必要ない場合は、このコンストラクターを使用します。
      パラメーター:
      url - URL。
      clientId - クライアント ID。

    • MqttPahoMessageHandler

      public MqttPahoMessageHandler(StringSE url, StringSE clientId, MqttPahoClientFactory clientFactory)
      単一の URL に対してこのコンストラクターを使用します（ただし、サーバー URI が MqttPahoClientFactory によって提供される MqttConnectOptions.getServerURIs() によって提供される場合はオーバーライドされる場合があります）。
      パラメーター:
      url - URL。
      clientId - クライアント ID。
      clientFactory - クライアントファクトリ。

    • MqttPahoMessageHandler

      public MqttPahoMessageHandler(StringSE clientId, MqttPahoClientFactory clientFactory)
      サーバー URI が MqttPahoClientFactory によって提供される MqttConnectOptions.getServerURIs() によって提供される場合、このコンストラクターを使用します。
      パラメーター:
      clientId - クライアント ID。
      clientFactory - クライアントファクトリ。
      導入:
      4.1

    • MqttPahoMessageHandler

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

  • メソッドの詳細

    • setAsync

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

    • setAsyncEvents

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

    • getConnectionInfo

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

    • onInit

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

    • doStart

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

    • doStop

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

    • publish

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

    • connectionLost

      public void connectionLost(ThrowableSE cause)
      次で指定:
      インターフェース org.eclipse.paho.client.mqttv3.MqttCallback の connectionLost 

    • messageArrived

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

    • deliveryComplete

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