サービスの品質および接続の管理

MQTTSubscribe ノードの動作

受信メッセージの QoS レベルは、MQTT サーバーから IBM Integration Busへのメッセージの転送にのみ適用されます。 QoS 0 のメッセージが Paho クライアントによって正常に受信されると、 MQTTSubscribe ノードはメッセージを Out ターミナルに伝搬します。 QoS 1 または QoS 2 のメッセージを正常に受信した場合は、Paho クライアントは、そのメッセージがノードによって処理されるようにするため、メッセージの受信について肯定応答する必要があります。 転送が正常に確認されて完了した後は、QoS レベルは IBM Integration Busによるメッセージの処理方法にはこれ以上影響しません。

MQTT サーバーへのネットワーク接続が失われた場合、 MQTTSubscribe ノードは 5 秒後に接続を再試行します。 再接続の試行間隔は、試行のたびに 5 秒ずつ延び、最大 2 分間隔となります。 再接続の試行回数には制限がありません。 これらの試行は、MQTT アクティビティー・ログに記録されます。

メッセージが IBM Integration Busによって処理できる速度より速く到着した場合、メッセージ受信は、メッセージ・フローがメッセージを処理できるようになるまでブロックされます。

MQTTSubscribe ノードがメッセージを受信すると、 サービスの品質 変数を使用して、ローカル環境にメッセージの QoS が取り込まれます。 ローカル環境変数について詳しくは、 MQTTSubscribe ノードを参照してください。

MQTTPublish ノードの動作

パブリッシュされたメッセージの QoS レベルは、 IBM Integration Bus から MQTT サーバーへのメッセージの転送に適用されます。 MQTTPublish ノードが QoS 0 のメッセージをパブリッシュする場合、転送の確認応答は予期されません。 MQTTPublish ノードが QoS 1 または QoS 2 のメッセージをパブリッシュすると、ノードは、MQTT サーバーがメッセージの受信を確認したことを Paho クライアントが確認するまで最大 30 秒間待機します。 この時間を過ぎても肯定応答が受信されない場合、ノードはパブリッシュを再試行します。 この 2 回目の試行が失敗すると、メッセージ BIP12099 とともに例外が生成され、ノードはこのメッセージを Failure ターミナルに伝搬します (ノードに Failure ターミナルが接続されている場合)。 Failure ターミナルが接続されていない場合、メッセージは入力ノードにロールバックされます。

トランスポートの問題の診断

ネットワーク・レベルで接続障害があると、メッセージ BIP12096 とともに例外が生成されます。 MQTT リソース統計の測定値 FailedConnections (統合サーバーの最後の再始動以降に失敗した、MQTT サーバーへの接続試行の総数を報告する) も増加します。