This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch remove-set-adapters
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 94a2d5373 [#1289] First generic adapter works now
add a01f0941d Add integration test for MQTT (#1485) (#1489)
add 4f14ed0f1 Merge branch 'dev' into remove-set-adapters
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 | 4 +-
.../integration/adapters/AdaptersTest.java | 14 +++
.../integration/adapters/MqttAdapterTester.java | 129 +++++++++++++++++++++
...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, 257 insertions(+), 40 deletions(-)
create mode 100644
streampipes-integration-tests/src/test/java/org/apache/streampipes/integration/adapters/MqttAdapterTester.java
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%)
