AbstractMqttMessageDrivenChannelAdapter (Spring Integration API)

java.lang.ObjectSE
- org.springframework.integration.context.IntegrationObjectSupport
- - org.springframework.integration.endpoint.AbstractEndpoint
  - - org.springframework.integration.endpoint.MessageProducerSupport
    - - org.springframework.integration.mqtt.inbound.AbstractMqttMessageDrivenChannelAdapter

実装されたすべてのインターフェース:
Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, SmartInitializingSingleton, ApplicationContextAware, Lifecycle, Phased, SmartLifecycle, ExpressionCapable, MessageProducer, IntegrationPattern, NamedComponent, ManageableLifecycle, ManageableSmartLifecycle, TrackableComponent
既知の直属サブクラス
MqttPahoMessageDrivenChannelAdapter
```
@ManagedResource
 @IntegrationManagedResource
public abstract class AbstractMqttMessageDrivenChannelAdapter
extends MessageProducerSupport
```
MQTT メッセージ駆動型チャネルアダプターの抽象クラス。
導入:
4.0
作成者:
Gary Russell, Artem Bilan

フィールドのサマリー
フィールド
修飾子と型フィールドと説明
protected LockSE topicLock
- クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたフィールド
  lifecycleCondition, lifecycleLock
- クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド
  EXPRESSION_PARSER, logger
- インターフェース org.springframework.context.SmartLifecycle から継承されたフィールド
  DEFAULT_PHASE

フィールド
修飾子と型	フィールドと説明
`protected LockSE`	`topicLock`

コンストラクターの概要
コンストラクター
コンストラクターと説明
AbstractMqttMessageDrivenChannelAdapter(StringSE url, StringSE clientId, StringSE... topic)

コンストラクター
コンストラクターと説明
`AbstractMqttMessageDrivenChannelAdapter(StringSE url, StringSE clientId, StringSE... topic)`

メソッドのサマリー

すべてのメソッドインスタンスメソッド具象メソッド
修飾子と型	メソッドと説明
`void`	`addTopic(StringSE... topic)` トピックをサブスクライブリストに追加します（qos = 1）。
`void`	`addTopic(StringSE topic, int qos)` トピックを購読リストに追加します。
`void`	`addTopics(StringSE[] topic, int[] qos)` トピックを購読リストに追加します。
`protected StringSE`	`getClientId()`
`StringSE`	`getComponentType()` サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。
`protected MqttMessageConverter`	`getConverter()`
`int[]`	`getQos()`
`StringSE[]`	`getTopic()`
`protected StringSE`	`getUrl()`
`protected void`	`onInit()` サブクラスは、初期化ロジック用にこれを実装できます。
`void`	`removeTopic(StringSE... topic)` 購読リストからトピックを削除します。
`void`	`setConverter(MqttMessageConverter converter)`
`void`	`setQos(int... qos)` 各トピックの QoS を設定します。単一の値がすべてのトピックに適用されます。それ以外の場合は、正しい数の QoS 値を指定する必要があります。

クラス org.springframework.integration.endpoint.MessageProducerSupport から継承されたメソッド
afterSingletonsInstantiated, buildErrorMessage, doStart, doStop, getErrorChannel, getErrorMessageAttributes, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack, subscribeToPublisher

クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたメソッド
destroy, doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stop

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

クラス java.lang.ObjectSE から継承されたメソッド
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, waitSE, waitSE, waitSE

インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド
getBeanName, getComponentName

- フィールドの詳細
  - topicLock
```
protected final LockSE topicLock
```
- コンストラクターの詳細
  - AbstractMqttMessageDrivenChannelAdapter
```
public AbstractMqttMessageDrivenChannelAdapter(@Nullable
                                               StringSE url,
                                               StringSE clientId,
                                               StringSE... topic)
```
- メソッドの詳細
  - setConverter
```
public void setConverter(MqttMessageConverter converter)
```
  - setQos
```
public void setQos(int... qos)
```
    各トピックの QoS を設定します。単一の値がすべてのトピックに適用されます。それ以外の場合は、正しい数の QoS 値を指定する必要があります。
    パラメーター:
    qos - QoS 値。
    導入:
    4.1
  - getQos
```
@ManagedAttribute
public int[] getQos()
```
  - getUrl
```
@Nullable
protected StringSE getUrl()
```
  - getClientId
```
protected StringSE getClientId()
```
  - getConverter
```
protected MqttMessageConverter getConverter()
```
  - getTopic
```
@ManagedAttribute
public StringSE[] getTopic()
```
  - getComponentType
```
public StringSE getComponentType()
```
    クラスからコピーされた説明: IntegrationObjectSupport
    サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。
    次で指定:
    インターフェース NamedComponent の getComponentType
    オーバーライド:
    クラス IntegrationObjectSupport の getComponentType
  - addTopic
```
@ManagedOperation
public void addTopic(StringSE topic,
                                       int qos)
```
    トピックを購読リストに追加します。
    パラメーター:
    topic - トピック。
    qos - QoS。
    例外:
    MessagingException - トピックがすでにリストにある場合。
    導入:
    4.1
  - addTopic
```
@ManagedOperation
public void addTopic(StringSE... topic)
```
    トピックをサブスクライブリストに追加します（qos = 1）。
    パラメーター:
    topic - トピック。
    例外:
    MessagingException - トピックがすでにリストにある場合。
    導入:
    4.1
  - addTopics
```
@ManagedOperation
public void addTopics(StringSE[] topic,
                                        int[] qos)
```
    トピックを購読リストに追加します。
    パラメーター:
    topic - トピック。
    qos - 各トピックの QoS。
    例外:
    MessagingException - トピックがすでにリストにある場合。
    導入:
    4.1
  - removeTopic
```
@ManagedOperation
public void removeTopic(StringSE... topic)
```
    購読リストからトピックを削除します。
    パラメーター:
    topic - トピック。
    例外:
    MessagingException - トピックがリストにない場合。
    導入:
    4.1
  - onInit
```
protected void onInit()
```
    クラスからコピーされた説明: IntegrationObjectSupport
    サブクラスは、初期化ロジック用にこれを実装できます。
    オーバーライド:
    クラス MessageProducerSupport の onInit

クラス AbstractMqttMessageDrivenChannelAdapter

フィールドのサマリー

クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたフィールド

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド

インターフェース org.springframework.context.SmartLifecycle から継承されたフィールド

コンストラクターの概要

メソッドのサマリー

クラス org.springframework.integration.endpoint.MessageProducerSupport から継承されたメソッド

クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたメソッド

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド

クラス java.lang.ObjectSE から継承されたメソッド

インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド

フィールドの詳細

topicLock

コンストラクターの詳細

AbstractMqttMessageDrivenChannelAdapter

メソッドの詳細

setConverter

setQos

getQos

getUrl

getClientId

getConverter

getTopic

getComponentType

addTopic

addTopic

addTopics

removeTopic

onInit