This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from b814989fb5 refactor(#3927): migrate all data sinks from
streampipesdatasink to istreampipesdatasink (#3928)
add 3539cc35d3 Replaced the library fusesource/mqtt with hiveMq (#3934)
No new revisions were added by this update.
Summary of changes:
pom.xml | 19 +++-
.../streampipes-connectors-mqtt/pom.xml | 7 +-
.../mqtt/migration/MQTTAdapterMigrationV1.java | 10 +-
.../connectors/mqtt/security/SecurityUtils.java | 70 +++++++++---
.../connectors/mqtt/shared/MqttBase.java | 84 +++++++++------
.../connectors/mqtt/shared/MqttConfig.java | 19 ++--
.../connectors/mqtt/shared/MqttConnectUtils.java | 29 +++--
.../connectors/mqtt/shared/MqttConsumer.java | 90 ++++++++++++----
.../connectors/mqtt/shared/MqttPublisher.java | 56 +++++-----
.../streampipes-sinks-brokers-jvm/pom.xml | 6 +-
streampipes-integration-tests/pom.xml | 2 +-
.../adapters/AdaptersIntegrationTest.java | 16 +--
.../integration/adapters/MqttAdapterTLSTester.java | 1 -
.../src/test/resources/truststore.jks | Bin 0 -> 1238 bytes
streampipes-messaging-mqtt/pom.xml | 4 +-
.../messaging/mqtt/AbstractMqttConnector.java | 46 ++++----
.../streampipes/messaging/mqtt/MqttConsumer.java | 118 +++++++++++----------
.../streampipes/messaging/mqtt/MqttPublisher.java | 87 ++++++++-------
18 files changed, 399 insertions(+), 265 deletions(-)
create mode 100644
streampipes-integration-tests/src/test/resources/truststore.jks
