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

クラス MqttPahoMessageDrivenChannelAdapter

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.endpoint.MessageProducerSupport
org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter<org.eclipse.paho.client.mqttv3.IMqttAsyncClient,org.eclipse.paho.client.mqttv3.MqttConnectOptions>
org.springframework.integration.mqtt.inbound.MqttPahoMessageDrivenChannelAdapter
実装されたすべてのインターフェース:
org.eclipse.paho.client.mqttv3.MqttCallback、org.eclipse.paho.client.mqttv3.MqttCallbackExtended、Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、SmartInitializingSingleton、ApplicationContextAware、ApplicationEventPublisherAware、Lifecycle、Phased、SmartLifecycle、ExpressionCapable、MessageProducer、IntegrationPattern、ClientManager.ConnectCallback、MqttComponent<org.eclipse.paho.client.mqttv3.MqttConnectOptions>、MqttPahoComponent、NamedComponent、IntegrationInboundManagement、IntegrationManagement、ManageableLifecycle、ManageableSmartLifecycle、TrackableComponent
public class MqttPahoMessageDrivenChannelAdapter extends AbstractMqttMessageDrivenChannelAdapter<org.eclipse.paho.client.mqttv3.IMqttAsyncClient,org.eclipse.paho.client.mqttv3.MqttConnectOptions> implements org.eclipse.paho.client.mqttv3.MqttCallbackExtended, MqttPahoComponent
Eclipse Paho の実装。このコンポーネントによって公開された MqttIntegrationEvent を使用する場合は、MqttPahoComponent adapter = event.getSourceAsType() を使用して参照を取得し、Bean 名と MqttConnectOptions を取得できるようにします。この手法により、同じイベントリスナー内の受信エンドポイントと送信エンドポイントの両方からのイベントを利用できます。
導入:
4.0
作成者:
Gary Russell, Artem Bilan, Artem Vozhdayenko

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

    • MqttPahoMessageDrivenChannelAdapter

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

    • MqttPahoMessageDrivenChannelAdapter

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

    • MqttPahoMessageDrivenChannelAdapter

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

    • MqttPahoMessageDrivenChannelAdapter

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

  • メソッドの詳細

    • 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
      サブクラスは、初期化ロジック用にこれを実装できます。
      オーバーライド:
      クラス AbstractMqttMessageDrivenChannelAdapter<org.eclipse.paho.client.mqttv3.IMqttAsyncClient,org.eclipse.paho.client.mqttv3.MqttConnectOptions> の onInit 

    • doStart

      protected void doStart()
      クラスからコピーされた説明: MessageProducerSupport
      デフォルトでは何もしません。サブクラスは、ライフサイクル管理の動作が必要な場合、これをオーバーライドできます。"lifecycleLock" によって保護されています。
      オーバーライド:
      クラス MessageProducerSupport の doStart 

    • doStop

      protected void doStop()
      クラスからコピーされた説明: MessageProducerSupport
      デフォルトでは何もしません。サブクラスは、ライフサイクル管理の動作が必要な場合、これをオーバーライドできます。
      オーバーライド:
      クラス MessageProducerSupport の doStop 

    • destroy

      public void destroy()
      次で指定:
      インターフェース DisposableBean の destroy 
      次で指定:
      インターフェース IntegrationManagement の destroy 
      オーバーライド:
      クラス AbstractMqttMessageDrivenChannelAdapter<org.eclipse.paho.client.mqttv3.IMqttAsyncClient,org.eclipse.paho.client.mqttv3.MqttConnectOptions> の destroy 

    • addTopic

      public void addTopic(StringSE topic, int qos)
      クラスからコピーされた説明: AbstractMqttMessageDrivenChannelAdapter
      トピックを購読リストに追加します。
      オーバーライド:
      クラス AbstractMqttMessageDrivenChannelAdapter<org.eclipse.paho.client.mqttv3.IMqttAsyncClient,org.eclipse.paho.client.mqttv3.MqttConnectOptions> の addTopic 
      パラメーター:
      topic - トピック。
      qos - QoS。

    • removeTopic

      public void removeTopic(StringSE... topic)
      クラスからコピーされた説明: AbstractMqttMessageDrivenChannelAdapter
      購読リストからトピックを削除します。
      オーバーライド:
      クラス AbstractMqttMessageDrivenChannelAdapter<org.eclipse.paho.client.mqttv3.IMqttAsyncClient,org.eclipse.paho.client.mqttv3.MqttConnectOptions> の removeTopic 
      パラメーター:
      topic - トピック。

    • 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 mqttMessage)
      次で指定:
      インターフェース 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 

    • connectComplete

      public void connectComplete(boolean isReconnect)
      インターフェースからコピーされた説明: ClientManager.ConnectCallback
      サーバーへの接続が正常に完了したときに呼び出されます。
      次で指定:
      インターフェース ClientManager.ConnectCallback の connectComplete 
      パラメーター:
      isReconnect - true の場合、接続は自動再接続の結果です。

    • connectComplete

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