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(-)
