This is an automated email from the ASF dual-hosted git repository.
riemer pushed a change to branch refactor-extension-modules
in repository https://gitbox.apache.org/repos/asf/streampipes.git
from 0e80873d4 Add sinks to extensions-all-jvm
add 7717209ce Move MQTT and nats connectors to their own module
No new revisions were added by this update.
Summary of changes:
streampipes-extensions/pom.xml | 2 +
.../streampipes-connect-adapters-iiot/pom.xml | 14 +-
.../connect/iiot/ConnectAdapterIiotInit.java | 4 +-
.../iiot/adapters/iolink/IfmAlMqttAdapter.java | 6 +-
.../streampipes-connect-adapters/pom.xml | 5 +
.../connect/adapters/flic/FlicMQTTAdapter.java | 6 +-
.../connect/adapters/netio/NetioMQTTAdapter.java | 6 +-
.../connect/adapters/ti/TISensorTag.java | 6 +-
.../pom.xml | 12 +-
.../connectors/mqtt/adapter}/MqttProtocol.java | 8 +-
.../connectors/mqtt/shared}/MqttConfig.java | 2 +-
.../connectors/mqtt/shared}/MqttConnectUtils.java | 2 +-
.../connectors/mqtt/shared}/MqttConsumer.java | 2 +-
.../connectors/mqtt/sink/MqttPublisherSink.java | 157 +++++++++++++++++++++
.../connectors/mqtt/sink/common}/MqttClient.java | 8 +-
.../connectors/mqtt/sink}/common/MqttOptions.java | 46 +++---
.../connectors/mqtt/sink}/common/MqttUtils.java | 2 +-
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../pom.xml | 9 +-
.../connectors/nats/adapter}/NatsProtocol.java | 30 ++--
.../connectors/nats/shared}/NatsConfigUtils.java | 2 +-
.../extensions/connectors/nats/sink/NatsSink.java} | 58 ++++----
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../extensions/all/iiot/AllExtensionsIIoTInit.java | 4 +
.../extensions/all/jvm/AllExtensionsInit.java | 4 +
.../streampipes-pipeline-elements-shared/pom.xml | 24 ----
.../streampipes-sinks-brokers-jvm/pom.xml | 5 -
.../sinks/brokers/jvm/BrokersJvmInit.java | 6 +-
.../sinks/brokers/jvm/mqtt/MqttPublisherSink.java | 153 --------------------
.../integration/adapters/MqttAdapterTester.java | 4 +-
40 files changed, 284 insertions(+), 303 deletions(-)
copy streampipes-extensions/{streampipes-connectors-tubemq =>
streampipes-connectors-mqtt}/pom.xml (84%)
rename
streampipes-extensions/{streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream
=>
streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/adapter}/MqttProtocol.java
(94%)
rename
streampipes-extensions/{streampipes-pipeline-elements-shared/src/main/java/org/apache/streampipes/pe/shared/config/mqtt
=>
streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/shared}/MqttConfig.java
(95%)
rename
streampipes-extensions/{streampipes-pipeline-elements-shared/src/main/java/org/apache/streampipes/pe/shared/config/mqtt
=>
streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/shared}/MqttConnectUtils.java
(98%)
rename
streampipes-extensions/{streampipes-pipeline-elements-shared/src/main/java/org/apache/streampipes/pe/shared/config/mqtt
=>
streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/shared}/MqttConsumer.java
(97%)
create mode 100644
streampipes-extensions/streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/sink/MqttPublisherSink.java
rename
streampipes-extensions/{streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/mqtt
=>
streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/sink/common}/MqttClient.java
(94%)
rename
streampipes-extensions/{streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/mqtt
=>
streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/sink}/common/MqttOptions.java
(67%)
rename
streampipes-extensions/{streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/mqtt
=>
streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/sink}/common/MqttUtils.java
(97%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-mqtt}/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.mqtt/documentation.md
(100%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-mqtt}/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.mqtt/icon.png
(100%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-mqtt}/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.mqtt/strings.en
(100%)
rename streampipes-extensions/{streampipes-sinks-brokers-jvm =>
streampipes-connectors-mqtt}/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.mqtt/documentation.md
(100%)
rename streampipes-extensions/{streampipes-sinks-brokers-jvm =>
streampipes-connectors-mqtt}/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.mqtt/icon.png
(100%)
rename streampipes-extensions/{streampipes-sinks-brokers-jvm =>
streampipes-connectors-mqtt}/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.mqtt/strings.en
(100%)
copy streampipes-extensions/{streampipes-connectors-tubemq =>
streampipes-connectors-nats}/pom.xml (88%)
rename
streampipes-extensions/{streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream
=>
streampipes-connectors-nats/src/main/java/org/apache/streampipes/extensions/connectors/nats/adapter}/NatsProtocol.java
(82%)
rename
streampipes-extensions/{streampipes-pipeline-elements-shared/src/main/java/org/apache/streampipes/pe/shared/config/nats
=>
streampipes-connectors-nats/src/main/java/org/apache/streampipes/extensions/connectors/nats/shared}/NatsConfigUtils.java
(97%)
rename
streampipes-extensions/{streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/nats/NatsController.java
=>
streampipes-connectors-nats/src/main/java/org/apache/streampipes/extensions/connectors/nats/sink/NatsSink.java}
(74%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-nats}/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.nats/documentation.md
(100%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-nats}/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.nats/icon.png
(100%)
rename streampipes-extensions/{streampipes-connect-adapters-iiot =>
streampipes-connectors-nats}/src/main/resources/org.apache.streampipes.connect.iiot.protocol.stream.nats/strings.en
(100%)
rename streampipes-extensions/{streampipes-sinks-brokers-jvm =>
streampipes-connectors-nats}/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.nats/documentation.md
(100%)
rename streampipes-extensions/{streampipes-sinks-brokers-jvm =>
streampipes-connectors-nats}/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.nats/icon.png
(100%)
rename streampipes-extensions/{streampipes-sinks-brokers-jvm =>
streampipes-connectors-nats}/src/main/resources/org.apache.streampipes.sinks.brokers.jvm.nats/strings.en
(100%)
delete mode 100644
streampipes-extensions/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/mqtt/MqttPublisherSink.java
