You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@nifi.apache.org by tu...@apache.org on 2022/10/06 16:25:02 UTC

[nifi] branch main updated (a721e03000 -> 2405b0ef71)

This is an automated email from the ASF dual-hosted git repository.

turcsanyi pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git


    from a721e03000 NIFI-10596 Update Test Containers
     add 2405b0ef71 NIFI-10543 Support broker failover in MQTT processors (#6447)

No new revisions were added by this update.

Summary of changes:
 .../apache/nifi/processors/mqtt/ConsumeMQTT.java   | 34 ++++-----
 .../apache/nifi/processors/mqtt/PublishMQTT.java   | 21 ++---
 .../mqtt/adapters/HiveMqV5ClientAdapter.java       | 21 ++---
 .../mqtt/adapters/PahoMqttClientAdapter.java       |  9 ++-
 .../mqtt/common/AbstractMQTTProcessor.java         | 89 ++++++++++++++--------
 .../processors/mqtt/common/MqttClientFactory.java  | 44 ++++++++++-
 .../mqtt/common/MqttClientProperties.java          | 61 ++++++++++++---
 .../nifi/processors/mqtt/TestConsumeMQTT.java      | 62 +++++++++++++--
 8 files changed, 242 insertions(+), 99 deletions(-)