クラス AbstractMqttMessageHandler<T,C>

メソッドの詳細

• setApplicationEventPublisher

  public void setApplicationEventPublisher(ApplicationEventPublisher applicationEventPublisher)

  次で指定:

  インターフェース ApplicationEventPublisherAware の setApplicationEventPublisher 

• getApplicationEventPublisher

  protected ApplicationEventPublisher getApplicationEventPublisher()

• setDefaultTopic

  public void setDefaultTopic(StringSE defaultTopic)

  topicExpression が `null` と評価された場合にメッセージが公開されるトピックを設定します。

  パラメーター:

  defaultTopic - デフォルトのトピック。

• getDefaultTopic

  protected StringSE getDefaultTopic()

• setTopicExpression

  public void setTopicExpression(Expression topicExpression)

  トピック式を設定します。デフォルトは "headers ['mqtt_topic' ]" です。

  パラメーター:

  topicExpression - 表現。

  導入:

  5.0

• setTopicExpressionString

  public void setTopicExpressionString(StringSE topicExpression)

  トピック式を設定します。デフォルトは "headers ['mqtt_topic' ]" です。

  パラメーター:

  topicExpression - 表現。

  導入:

  5.0

• getTopicProcessor

  protected MessageProcessor<StringSE> getTopicProcessor()

• setDefaultQos

  public void setDefaultQos(int defaultQos)

  qosExpression が null と評価される場合、メッセージの qos を設定します。メッセージコンバーターが提供されていない場合にのみ適用されます。

  パラメーター:

  defaultQos - デフォルトの QoS。

  関連事項:

  • setConverter(MessageConverter)

• getDefaultQos

  protected int getDefaultQos()

• setQosExpression

  public void setQosExpression(Expression qosExpression)

  qos 式を設定します。デフォルトは "headers ['mqtt_qos' ]" です。メッセージコンバーターが提供されていない場合にのみ適用されます。

  パラメーター:

  qosExpression - 表現。

  導入:

  5.0

  関連事項:

  • setConverter(MessageConverter)

• setQosExpressionString

  public void setQosExpressionString(StringSE qosExpression)

  qos 式を設定します。デフォルトは "headers ['mqtt_qos' ]" です。メッセージコンバーターが提供されていない場合にのみ適用されます。

  パラメーター:

  qosExpression - 表現。

  導入:

  5.0

  関連事項:

  • setConverter(MessageConverter)

• getQosProcessor

  protected MessageProcessor<IntegerSE> getQosProcessor()

• setDefaultRetained

  public void setDefaultRetained(boolean defaultRetained)

  retainedExpression が null と評価された場合、メッセージの保持ブール値を設定します。メッセージコンバーターが提供されていない場合にのみ適用されます。

  パラメーター:

  defaultRetained - デフォルトの defaultRetained。

  関連事項:

  • setConverter(MessageConverter)

• getDefaultRetained

  protected boolean getDefaultRetained()

• setRetainedExpression

  public void setRetainedExpression(Expression retainedExpression)

  保持された式を設定します。デフォルトは "headers ['mqtt_retained' ]" です。メッセージコンバーターが提供されていない場合にのみ適用されます。

  パラメーター:

  retainedExpression - 表現。

  導入:

  5.0

  関連事項:

  • setConverter(MessageConverter)

• setRetainedExpressionString

  public void setRetainedExpressionString(StringSE retainedExpression)

  保持された式を設定します。デフォルトは "headers ['mqtt_retained' ]" です。メッセージコンバーターが提供されていない場合にのみ適用されます。

  パラメーター:

  retainedExpression - 表現。

  導入:

  5.0

  関連事項:

  • setConverter(MessageConverter)

• getRetainedProcessor

  protected MessageProcessor<BooleanSE> getRetainedProcessor()

• setConverter

  public void setConverter(MessageConverter converter)

  使用するメッセージコンバーターを設定します。これが指定されている場合、アダプターの QoS および保持されている設定は無視されます。

  パラメーター:

  converter - コンバーター。

• getConverter

  protected MessageConverter getConverter()

• getUrl

  @Nullable protected StringSE getUrl()

• getClientId

  @Nullable public StringSE getClientId()

• getClientInstance

  public int getClientInstance()

  クライアントが接続されるたびに増加します。

  戻り値:

  インスタンス。

  導入:

  4.1

• getComponentType

  public StringSE getComponentType()

  クラスからコピーされた説明: IntegrationObjectSupport

  サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。

  次で指定:

  インターフェース NamedComponent の getComponentType 

  オーバーライド:

  クラス MessageHandlerSupport の getComponentType 

• incrementClientInstance

  protected void incrementClientInstance()

• setCompletionTimeout

  public void setCompletionTimeout(long completionTimeout)

  非同期操作の完了タイムアウトを設定します。名前空間を使用して設定することはできません。デフォルトは 30000L < T、C > ミリ秒です。

  パラメーター:

  completionTimeout - タイムアウト。

  導入:

  4.1

• getCompletionTimeout

  protected long getCompletionTimeout()

• setDisconnectCompletionTimeout

  public void setDisconnectCompletionTimeout(long completionTimeout)

  切断時の完了タイムアウトを設定します。名前空間を使用して設定することはできません。デフォルトは 5000L < T、C > ミリ秒です。

  パラメーター:

  completionTimeout - タイムアウト。

  導入:

  5.1.10

• getDisconnectCompletionTimeout

  protected long getDisconnectCompletionTimeout()

• getClientManager

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

• setAsync

  public void setAsync(boolean async)

  メッセージを送信するときにブロックしない場合は、true に設定します。デフォルトは false。true の場合、メッセージ送信 / 配信イベントは、適切に構成された "ApplicationListener" またはイベント inbound-channel-adapter による受信のために公開されます。

  パラメーター:

  async - 非同期の場合は true。

  関連事項:

  • setAsyncEvents(boolean)

• isAsync

  protected boolean isAsync()

• setAsyncEvents

  public void setAsyncEvents(boolean asyncEvents)

  setAsync(boolean) が true の場合、これを true に設定すると、MqttMessageSentEvent および MqttMessageDeliveredEvent の発行が発行されます。デフォルトは false。

  パラメーター:

  asyncEvents - asyncEvents。

• onInit

  protected void onInit()

  クラスからコピーされた説明: IntegrationObjectSupport

  サブクラスは、初期化ロジック用にこれを実装できます。

  オーバーライド:

  クラス IntegrationObjectSupport の onInit 

• start

  public final void start()

  次で指定:

  インターフェース Lifecycle の start 

  次で指定:

  インターフェース ManageableLifecycle の start 

• doStart

  protected abstract void doStart()

• stop

  public final void stop()

  次で指定:

  インターフェース Lifecycle の stop 

  次で指定:

  インターフェース ManageableLifecycle の stop 

• doStop

  protected abstract void doStop()

• isRunning

  public boolean isRunning()

  次で指定:

  インターフェース Lifecycle の isRunning 

  次で指定:

  インターフェース ManageableLifecycle の isRunning 

• handleMessageInternal

  protected void handleMessageInternal(Message<?> message)

  次で指定:

  クラス AbstractMessageHandler の handleMessageInternal 

• messageSentEvent

  protected void messageSentEvent(Message<?> message, StringSE topic, int messageId)

• sendDeliveryCompleteEvent

  protected void sendDeliveryCompleteEvent(int messageId)

• sendFailedDeliveryEvent

  protected void sendFailedDeliveryEvent(int messageId, ThrowableSE exception)

• publish

  protected abstract void publish(StringSE topic, ObjectSE mqttMessage, Message<?> message)