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

クラス AbstractMqttMessageDrivenChannelAdapter<T,C>

java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.endpoint.AbstractEndpoint
org.springframework.integration.endpoint.MessageProducerSupport
org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter<T,C>
型パラメーター:
T - MQTT クライアントの種類
C - MQTT 接続オプション型 (v5 または v3)
実装されたすべてのインターフェース:
Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、SmartInitializingSingleton、ApplicationContextAware、ApplicationEventPublisherAware、Lifecycle、Phased、SmartLifecycle、ExpressionCapable、MessageProducer、IntegrationPattern、ClientManager.ConnectCallback、NamedComponent、IntegrationInboundManagement、IntegrationManagement、ManageableLifecycle、ManageableSmartLifecycle、TrackableComponent
既知の直属サブクラス
MqttPahoMessageDrivenChannelAdapter, Mqttv5PahoMessageDrivenChannelAdapter
@ManagedResource @IntegrationManagedResource public abstract class AbstractMqttMessageDrivenChannelAdapter<T,C> extends MessageProducerSupport implements ApplicationEventPublisherAware, ClientManager.ConnectCallback
MQTT メッセージ駆動型チャネルアダプターの抽象クラス。
導入:
4.0
作成者:
Gary Russell, Artem Bilan, Trung Pham, Mikhail Polivakha, Artem Vozhdayenko

  • フィールドの詳細

    • topicLock

      protected final LockSE topicLock

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

    • AbstractMqttMessageDrivenChannelAdapter

      public AbstractMqttMessageDrivenChannelAdapter(@Nullable StringSE url, StringSE clientId, StringSE... topic)

    • AbstractMqttMessageDrivenChannelAdapter

      public AbstractMqttMessageDrivenChannelAdapter(ClientManager<T,C> clientManager, StringSE... topic)

  • メソッドの詳細

    • setConverter

      public void setConverter(MqttMessageConverter converter)

    • getClientManager

      @Nullable protected ClientManager<T,C> getClientManager()

    • setQos

      public void setQos(int... qos)
      各トピックの QoS を設定します。単一の値がすべてのトピックに適用されます。それ以外の場合は、正しい数の QoS 値を指定する必要があります。
      パラメーター:
      qos - QoS 値。
      導入:
      4.1

    • getQos

      @ManagedAttribute public int[] getQos()

    • getUrl

      @Nullable protected StringSE getUrl()

    • getClientId

      @Nullable protected StringSE getClientId()

    • getConverter

      protected MqttMessageConverter getConverter()

    • getTopic

      @ManagedAttribute public StringSE[] getTopic()

    • setDisconnectCompletionTimeout

      public void setDisconnectCompletionTimeout(long completionTimeout)
      切断時の補完タイムアウトを設定します。デフォルトの 5000L ミリ秒。
      パラメーター:
      completionTimeout - タイムアウト。
      導入:
      5.1.10

    • getDisconnectCompletionTimeout

      protected long getDisconnectCompletionTimeout()

    • onInit

      protected void onInit()
      クラスからコピーされた説明: IntegrationObjectSupport
      サブクラスは、初期化ロジック用にこれを実装できます。
      オーバーライド:
      クラス MessageProducerSupport の onInit 

    • destroy

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

    • getComponentType

      public StringSE getComponentType()
      クラスからコピーされた説明: IntegrationObjectSupport
      サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。
      次で指定:
      インターフェース NamedComponent の getComponentType 
      オーバーライド:
      クラス IntegrationObjectSupport の getComponentType 

    • setApplicationEventPublisher

      public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)
      次で指定:
      インターフェース ApplicationEventPublisherAware の setApplicationEventPublisher 

    • getApplicationEventPublisher

      protected ApplicationEventPublisher getApplicationEventPublisher()

    • setManualAcks

      public void setManualAcks(boolean manualAcks)
      確認モードを手動に設定します。
      パラメーター:
      manualAcks - 手動の ack に当てはまります。
      導入:
      5.3

    • isManualAcks

      protected boolean isManualAcks()

    • setCompletionTimeout

      public void setCompletionTimeout(long completionTimeout)
      操作の補完タイムアウトを設定します。デフォルトの 30000L ミリ秒。
      パラメーター:
      completionTimeout - タイムアウト。
      導入:
      4.1

    • getCompletionTimeout

      protected long getCompletionTimeout()

    • addTopic

      @ManagedOperation public void addTopic(StringSE topic, int qos)
      トピックを購読リストに追加します。
      パラメーター:
      topic - トピック。
      qos - QoS。
      例外:
      MessagingException - トピックがすでにリストにある場合。
      導入:
      4.1

    • addTopic

      @ManagedOperation public void addTopic(StringSE... topics)
      トピックをサブスクライブリストに追加します（qos = 1）。
      パラメーター:
      topics - トピック。
      例外:
      MessagingException - トピックがすでにリストにある場合。
      導入:
      4.1

    • addTopics

      @ManagedOperation public void addTopics(StringSE[] topics, int[] qos)
      トピックを購読リストに追加します。
      パラメーター:
      topics - トピック。
      qos - 各トピックの QoS。
      例外:
      MessagingException - トピックがすでにリストにある場合。
      導入:
      4.1

    • removeTopic

      @ManagedOperation public void removeTopic(StringSE... topic)
      購読リストからトピックを削除します。
      パラメーター:
      topic - トピック。
      例外:
      MessagingException - トピックがリストにない場合。
      導入:
      4.1