This is an automated email from the ASF dual-hosted git repository.
lordgamez pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi-minifi-cpp.git
from ba15abcd4 MINIFICPP-1885 Mark extensions not in a static list as
disabled
new faa16d683 MINIFICPP-1907 Add description to monadic operation wrappers
new e31ee031b MINIFICPP-1905 - Enumerate only relevant subdir contents
new 2abcb71ce MINIFICPP-1680 - Add support and tests for advanced MQTT
features
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
C2.md | 154 +---------
PROCESSORS.md | 73 +++--
bin/minifi.sh | 4 +
cmake/PahoMqttC.cmake | 4 +-
.../integration/MiNiFi_integration_test_driver.py | 19 +-
docker/test/integration/features/mqtt.feature | 228 +++++++++++++-
docker/test/integration/minifi/core/Cluster.py | 15 +
docker/test/integration/minifi/core/Container.py | 9 +
docker/test/integration/minifi/core/ImageStore.py | 2 +-
.../integration/minifi/core/MinifiContainer.py | 18 ++
.../minifi/core/SingleNodeDockerCluster.py | 26 +-
docker/test/integration/steps/steps.py | 35 ++-
extensions/mqtt/CMakeLists.txt | 6 +-
.../controllerservice/MQTTControllerService.cpp | 81 -----
.../mqtt/controllerservice/MQTTControllerService.h | 327 ---------------------
.../mqtt/processors/AbstractMQTTProcessor.cpp | 231 ++++++++-------
extensions/mqtt/processors/AbstractMQTTProcessor.h | 226 +++++++++-----
.../AbstractMQTTProcessorStaticDefinitions.cpp | 54 +++-
extensions/mqtt/processors/ConsumeMQTT.cpp | 95 ++++--
extensions/mqtt/processors/ConsumeMQTT.h | 75 +++--
extensions/mqtt/processors/ConvertBase.cpp | 44 ---
extensions/mqtt/processors/ConvertBase.h | 67 -----
.../processors/ConvertBaseStaticDefinitions.cpp | 51 ----
extensions/mqtt/processors/ConvertHeartBeat.cpp | 62 ----
extensions/mqtt/processors/ConvertHeartBeat.h | 52 ----
extensions/mqtt/processors/ConvertJSONAck.cpp | 84 ------
extensions/mqtt/processors/ConvertJSONAck.h | 58 ----
extensions/mqtt/processors/ConvertUpdate.cpp | 92 ------
extensions/mqtt/processors/ConvertUpdate.h | 66 -----
extensions/mqtt/processors/PublishMQTT.cpp | 70 +++--
extensions/mqtt/processors/PublishMQTT.h | 106 ++++---
extensions/mqtt/protocol/MQTTC2Protocol.cpp | 98 ------
extensions/mqtt/protocol/MQTTC2Protocol.h | 81 -----
extensions/mqtt/tests/CMakeLists.txt | 35 +++
extensions/mqtt/tests/ConsumeMQTTTests.cpp | 84 ++++++
extensions/mqtt/tests/PublishMQTTTests.cpp | 51 ++++
extensions/pdh/tests/CMakeLists.txt | 1 -
libminifi/include/core/Property.h | 18 +-
.../utils/detail/MonadicOperationWrappers.h | 29 ++
libminifi/include/utils/file/FileUtils.h | 21 +-
libminifi/test/mqtt-tests/CMakeLists.txt | 36 ---
libminifi/test/unit/FilePatternTests.cpp | 33 +++
42 files changed, 1178 insertions(+), 1743 deletions(-)
delete mode 100644 extensions/mqtt/controllerservice/MQTTControllerService.cpp
delete mode 100644 extensions/mqtt/controllerservice/MQTTControllerService.h
delete mode 100644 extensions/mqtt/processors/ConvertBase.cpp
delete mode 100644 extensions/mqtt/processors/ConvertBase.h
delete mode 100644 extensions/mqtt/processors/ConvertBaseStaticDefinitions.cpp
delete mode 100644 extensions/mqtt/processors/ConvertHeartBeat.cpp
delete mode 100644 extensions/mqtt/processors/ConvertHeartBeat.h
delete mode 100644 extensions/mqtt/processors/ConvertJSONAck.cpp
delete mode 100644 extensions/mqtt/processors/ConvertJSONAck.h
delete mode 100644 extensions/mqtt/processors/ConvertUpdate.cpp
delete mode 100644 extensions/mqtt/processors/ConvertUpdate.h
delete mode 100644 extensions/mqtt/protocol/MQTTC2Protocol.cpp
delete mode 100644 extensions/mqtt/protocol/MQTTC2Protocol.h
create mode 100644 extensions/mqtt/tests/CMakeLists.txt
create mode 100644 extensions/mqtt/tests/ConsumeMQTTTests.cpp
create mode 100644 extensions/mqtt/tests/PublishMQTTTests.cpp
delete mode 100644 libminifi/test/mqtt-tests/CMakeLists.txt
