This is an automated email from the ASF dual-hosted git repository.
bossenti pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 3f7324e72 [hotfix] exclude versions file from pydocs update (#1532)
add a01f0941d Add integration test for MQTT (#1485) (#1489)
No new revisions were added by this update.
Summary of changes:
.../adapter/format/util/JsonEventProperty.java | 35 ++++----
.../management/connect/adapter/TestUtils.java | 9 +++
.../format/json/object/JsonObjectParserTest.java | 12 +++
.../pe/shared/config/mqtt/MqttConnectUtils.java | 6 +-
.../sinks/brokers/jvm/mqtt/MqttClient.java | 4 +-
streampipes-integration-tests/pom.xml | 10 +++
.../integration/adapters/AdapterTesterBase.java | 3 +-
.../integration/adapters/AdaptersTest.java | 7 ++
...arAdapterTester.java => MqttAdapterTester.java} | 93 ++++++++++++----------
...arDevContainer.java => MosquittoContainer.java} | 31 ++++++--
.../containers/MosquittoDevContainer.java | 9 +--
.../src/test/resources/mosquitto.conf | 5 ++
.../couchdb/impl/ConnectionStorageImpl.java | 3 +-
.../event-property-row.component.ts | 26 ++++--
14 files changed, 171 insertions(+), 82 deletions(-)
copy
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/adapters/{PulsarAdapterTester.java
=> MqttAdapterTester.java} (55%)
copy
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/containers/{PulsarDevContainer.java
=> MosquittoContainer.java} (54%)
copy
streampipes-commons/src/main/java/org/apache/streampipes/commons/parser/PrimitiveTypeParser.java
=>
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/containers/MosquittoDevContainer.java
(82%)
copy streampipes-client-python/streampipes/function_zoo/__init__.py =>
streampipes-integration-tests/src/test/resources/mosquitto.conf (93%)
