You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ze...@apache.org on 2020/05/05 21:07:47 UTC
[incubator-streampipes-extensions] branch dev updated (76a00f2 ->
4a424c6)
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/incubator-streampipes-extensions.git.
from 76a00f2 OpenNLP models can now be uploaded into processors
add 91d1963 Remove package connect adapter
add 937da21 Modify connect pom, add ASF snapshot repo to parent pom
new 4a424c6 Fix dependencies of new connect package structure
The 1 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:
pom.xml | 233 ++++++++++++++++++++-
.../{streampipes-connect-adapter => }/Dockerfile | 4 +-
.../aarch64.Dockerfile | 0
.../arm.Dockerfile | 0
streampipes-connect-adapters/pom.xml | 112 +++++-----
.../streampipes/connect/ConnectAdapterInit.java | 0
.../streampipes/connect/adapters/PullAdapter.java | 0
.../connect/adapters/PullRestAdapter.java | 0
.../adapters/coindesk/CoindeskBitcoinAdapter.java | 0
.../connect/adapters/coindesk/Currency.java | 0
.../connect/adapters/coindesk/model/Bpi.java | 0
.../adapters/coindesk/model/CoindeskRawModel.java | 0
.../connect/adapters/coindesk/model/EUR.java | 0
.../connect/adapters/coindesk/model/GBP.java | 0
.../connect/adapters/coindesk/model/Time.java | 0
.../connect/adapters/coindesk/model/USD.java | 0
.../connect/adapters/gdelt/GdeltAdapter.java | 0
.../connect/adapters/iex/IexCloudAdapter.java | 0
.../connect/adapters/iex/IexCloudNewsAdapter.java | 0
.../connect/adapters/iex/IexCloudStockAdapter.java | 0
.../connect/adapters/iex/model/IexNewsData.java | 0
.../connect/adapters/iex/model/IexStockData.java | 0
.../connect/adapters/influxdb/InfluxDbClient.java | 0
.../adapters/influxdb/InfluxDbSetAdapter.java | 0
.../adapters/influxdb/InfluxDbStreamAdapter.java | 0
.../connect/adapters/iss/IssAdapter.java | 0
.../connect/adapters/iss/model/IssModel.java | 0
.../connect/adapters/iss/model/IssPosition.java | 0
.../streampipes/connect/adapters/mysql/Column.java | 0
.../connect/adapters/mysql/MySqlAdapter.java | 0
.../connect/adapters/mysql/MySqlClient.java | 0
.../connect/adapters/mysql/MySqlSetAdapter.java | 0
.../connect/adapters/mysql/MySqlStreamAdapter.java | 0
.../connect/adapters/netio/NetioMQTTAdapter.java | 0
.../connect/adapters/netio/NetioRestAdapter.java | 0
.../connect/adapters/netio/NetioUtils.java | 0
.../adapters/netio/model/NetioAllPowerOutputs.java | 0
.../adapters/netio/model/NetioGlobalMeasure.java | 0
.../adapters/netio/model/NetioPowerOutput.java | 0
.../trafficcamera/CameraDataHttpExecutor.java | 0
.../trafficcamera/CameraFeatureTransformer.java | 0
.../trafficcamera/CameraInfoHttpExecutor.java | 0
.../trafficcamera/NswTrafficCameraAdapter.java | 0
.../trafficcamera/TrafficCameraSensorNames.java | 0
.../nswaustralia/trafficcamera/model/Feature.java | 0
.../trafficcamera/model/FeatureCollection.java | 0
.../nswaustralia/trafficcamera/model/Geometry.java | 0
.../trafficcamera/model/Properties.java | 0
.../nswaustralia/trafficcamera/model/Rights.java | 0
.../connect/adapters/opcua/OpcNode.java | 0
.../streampipes/connect/adapters/opcua/OpcUa.java | 0
.../connect/adapters/opcua/OpcUaAdapter.java | 0
.../connect/adapters/opcua/OpcUaTypes.java | 0
.../plc4x/passive/Plc4xPassiveAdapter.java | 0
.../connect/adapters/plc4x/s7/Plc4xS7Adapter.java | 8 +
.../connect/adapters/ros/RosBridgeAdapter.java | 0
.../adapters/sensemap/OpenSenseMapAdapter.java | 0
.../connect/adapters/sensemap/SensorNames.java | 0
.../adapters/sensemap/model/CurrentLocation.java | 0
.../connect/adapters/sensemap/model/Geometry.java | 0
.../adapters/sensemap/model/LastMeasurement.java | 0
.../connect/adapters/sensemap/model/Loc.java | 0
.../connect/adapters/sensemap/model/SenseBox.java | 0
.../connect/adapters/sensemap/model/Sensor.java | 0
.../adapters/simulator/RandomDataSetAdapter.java | 0
.../adapters/simulator/RandomDataSimulator.java | 0
.../simulator/RandomDataSimulatorUtils.java | 0
.../simulator/RandomDataStreamAdapter.java | 0
.../connect/adapters/slack/SlackAdapter.java | 0
.../connect/adapters/slack/SlackConsumer.java | 0
.../connect/adapters/ti/TISensorTag.java | 0
.../adapters/wikipedia/WikipediaAdapter.java | 0
.../wikipedia/WikipediaEditedArticlesAdapter.java | 0
.../wikipedia/WikipediaModelConverter.java | 0
.../wikipedia/WikipediaNewArticlesAdapter.java | 0
.../adapters/wikipedia/WikipediaSseConsumer.java | 0
.../connect/adapters/wikipedia/model/Length.java | 0
.../connect/adapters/wikipedia/model/Meta.java | 0
.../connect/adapters/wikipedia/model/Revision.java | 0
.../adapters/wikipedia/model/WikipediaModel.java | 0
.../streampipes/connect/config/ConfigKeys.java | 0
.../connect/config/ConnectWorkerConfig.java | 0
.../connect/protocol/set/FileProtocol.java | 0
.../connect/protocol/set/HttpProtocol.java | 0
.../connect/protocol/stream/BrokerProtocol.java | 0
.../protocol/stream/FileStreamProtocol.java | 0
.../connect/protocol/stream/HDFSProtocol.java | 0
.../protocol/stream/HttpStreamProtocol.java | 0
.../connect/protocol/stream/KafkaProtocol.java | 0
.../connect/protocol/stream/MqttConfig.java | 0
.../connect/protocol/stream/MqttConsumer.java | 0
.../connect/protocol/stream/MqttProtocol.java | 0
.../connect/protocol/stream/PullProtocol.java | 0
.../connect/protocol/stream/WebsocketClient.java | 0
.../connect/protocol/stream/WebsocketProtocol.java | 0
.../protocol/stream/pulsar/PulsarConsumer.java | 0
.../protocol/stream/pulsar/PulsarProtocol.java | 0
.../protocol/stream/pulsar/PulsarUtils.java | 0
.../connect/utils/MqttConnectUtils.java | 0
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../documentation.md | 0
.../icon.png | Bin
.../strings.en | 0
.../connect/adapters/PullAdapterTest.java | 0
.../streampipes/connect/adapters/generic/Mock.java | 0
.../connect/adapters/generic/UtilTest.java | 0
.../generic/elements/AddTimestampTest.java | 0
.../generic/elements/DuplicateFilterTest.java | 0
.../generic/protocol/set/HttpProtocolTest.java | 0
.../generic/protocol/stream/HttpProtocolTest.java | 0
.../adapters/sensemap/OpenSenseMapAdapterTest.java | 0
.../connect/adapters/sensemap/SensorNamesTest.java | 0
.../connect/adapters/ti/TISensorTagTest.java | 0
.../streampipes-connect-adapter/pom.xml | 165 ---------------
streampipes-sinks-databases-jvm/pom.xml | 4 +-
.../sinks/databases/jvm/opcua/OpcUa.java | 18 +-
130 files changed, 297 insertions(+), 247 deletions(-)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/Dockerfile (86%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/aarch64.Dockerfile (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/arm.Dockerfile (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/ConnectAdapterInit.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/PullAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/PullRestAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/coindesk/CoindeskBitcoinAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/coindesk/Currency.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/Bpi.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/CoindeskRawModel.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/EUR.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/GBP.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/Time.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/coindesk/model/USD.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/gdelt/GdeltAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/iex/IexCloudAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/iex/IexCloudNewsAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/iex/IexCloudStockAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/iex/model/IexNewsData.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/iex/model/IexStockData.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/influxdb/InfluxDbClient.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/influxdb/InfluxDbSetAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/influxdb/InfluxDbStreamAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/iss/IssAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/iss/model/IssModel.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/iss/model/IssPosition.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/mysql/Column.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/mysql/MySqlAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/mysql/MySqlClient.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/mysql/MySqlSetAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/mysql/MySqlStreamAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/netio/NetioMQTTAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/netio/NetioRestAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/netio/NetioUtils.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/netio/model/NetioAllPowerOutputs.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/netio/model/NetioGlobalMeasure.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/netio/model/NetioPowerOutput.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/CameraDataHttpExecutor.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/CameraFeatureTransformer.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/CameraInfoHttpExecutor.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/NswTrafficCameraAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/TrafficCameraSensorNames.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/model/Feature.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/model/FeatureCollection.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/model/Geometry.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/model/Properties.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/nswaustralia/trafficcamera/model/Rights.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/opcua/OpcNode.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/opcua/OpcUa.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/opcua/OpcUaAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/opcua/OpcUaTypes.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/plc4x/passive/Plc4xPassiveAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/plc4x/s7/Plc4xS7Adapter.java (95%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/ros/RosBridgeAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/sensemap/OpenSenseMapAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/sensemap/SensorNames.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/CurrentLocation.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/Geometry.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/LastMeasurement.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/Loc.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/SenseBox.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/sensemap/model/Sensor.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/simulator/RandomDataSetAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/simulator/RandomDataSimulator.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/simulator/RandomDataSimulatorUtils.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/simulator/RandomDataStreamAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/slack/SlackAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/slack/SlackConsumer.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/ti/TISensorTag.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaEditedArticlesAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaModelConverter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaNewArticlesAdapter.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/WikipediaSseConsumer.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/model/Length.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/model/Meta.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/model/Revision.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/adapters/wikipedia/model/WikipediaModel.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/config/ConfigKeys.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/config/ConnectWorkerConfig.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/set/FileProtocol.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/set/HttpProtocol.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/BrokerProtocol.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/FileStreamProtocol.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/HDFSProtocol.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/HttpStreamProtocol.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/KafkaProtocol.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/MqttConfig.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/MqttConsumer.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/MqttProtocol.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/PullProtocol.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/WebsocketClient.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/WebsocketProtocol.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/pulsar/PulsarConsumer.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/pulsar/PulsarProtocol.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/protocol/stream/pulsar/PulsarUtils.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/java/org/apache/streampipes/connect/utils/MqttConnectUtils.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.adapters.iss/documentation.md (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.adapters.iss/icon.png (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.adapters.iss/strings.en (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.netio.rest => src/main/resources/org.apache.streampipes.connect.adapters.netio.mqtt}/documentation.md (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.netio.rest => src/main/resources/org.apache.streampipes.connect.adapters.netio.mqtt}/icon.png (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.adapters.netio.mqtt/strings.en (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.netio.mqtt => src/main/resources/org.apache.streampipes.connect.adapters.netio.rest}/documentation.md (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter/src/main/resources/org.apache.streampipes.connect.adapters.netio.mqtt => src/main/resources/org.apache.streampipes.connect.adapters.netio.rest}/icon.png (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.adapters.netio.rest/strings.en (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.adapters.ros/documentation.md (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.adapters.ros/icon.png (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.adapters.ros/strings.en (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.adapters.ti/documentation.md (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.adapters.ti/icon.png (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.adapters.ti/strings.en (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.protocol.stream.mqtt/documentation.md (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.protocol.stream.mqtt/icon.png (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/main/resources/org.apache.streampipes.connect.protocol.stream.mqtt/strings.en (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/test/java/org/apache/streampipes/connect/adapters/PullAdapterTest.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/test/java/org/apache/streampipes/connect/adapters/generic/Mock.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/test/java/org/apache/streampipes/connect/adapters/generic/UtilTest.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/test/java/org/apache/streampipes/connect/adapters/generic/elements/AddTimestampTest.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/test/java/org/apache/streampipes/connect/adapters/generic/elements/DuplicateFilterTest.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/test/java/org/apache/streampipes/connect/adapters/generic/protocol/set/HttpProtocolTest.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/test/java/org/apache/streampipes/connect/adapters/generic/protocol/stream/HttpProtocolTest.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/test/java/org/apache/streampipes/connect/adapters/sensemap/OpenSenseMapAdapterTest.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/test/java/org/apache/streampipes/connect/adapters/sensemap/SensorNamesTest.java (100%)
rename streampipes-connect-adapters/{streampipes-connect-adapter => }/src/test/java/org/apache/streampipes/connect/adapters/ti/TISensorTagTest.java (100%)
delete mode 100644 streampipes-connect-adapters/streampipes-connect-adapter/pom.xml
[incubator-streampipes-extensions] 01/01: Fix dependencies of new
connect package structure
Posted by ze...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git
commit 4a424c6cbfa7fab451ccd16c32d8d0655ec64c7a
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Tue May 5 23:06:55 2020 +0200
Fix dependencies of new connect package structure
---
pom.xml | 222 ++++++++++++++++++++-
streampipes-connect-adapters/pom.xml | 53 -----
streampipes-sinks-databases-jvm/pom.xml | 4 +-
.../sinks/databases/jvm/opcua/OpcUa.java | 18 +-
4 files changed, 227 insertions(+), 70 deletions(-)
diff --git a/pom.xml b/pom.xml
index 863a623..760e567 100644
--- a/pom.xml
+++ b/pom.xml
@@ -64,19 +64,30 @@
<streampipes.version>0.67.0-SNAPSHOT</streampipes.version>
<amqp-client.version>4.1.0</amqp-client.version>
+ <animal-sniffer-annotations.version>1.17</animal-sniffer-annotations.version>
<boofcv.version>0.33</boofcv.version>
+ <bcprov.version>1.61</bcprov.version>
<classindex.version>3.9</classindex.version>
+ <checker-qual.version>2.5.2</checker-qual.version>
<commons-math3.version>3.6.1</commons-math3.version>
+ <commons-compress.version>1.18</commons-compress.version>
+ <commons-text.version>1.4</commons-text.version>
<ditto-client.version>1.0.0</ditto-client.version>
<data-generator.version>1.4.1</data-generator.version>
<ddogleg.version>0.16</ddogleg.version>
+ <errorprone-annotations.version>2.2.0</errorprone-annotations.version>
<google-maps-services.version>0.10.0</google-maps-services.version>
<iotdb.version>0.8.0</iotdb.version>
+ <jackson.version>2.10.0</jackson.version>
+ <java-websocket.version>1.4.0</java-websocket.version>
+ <javax-validation.version>2.0.1.Final</javax-validation.version>
+ <javax-websocket-client-api.version>1.1</javax-websocket-client-api.version>
+ <jsrosbridge.version>0.2.0</jsrosbridge.version>
+
<language-detector.version>0.6</language-detector.version>
<log4j-to-slf4j.version>2.8.2</log4j-to-slf4j.version>
<mailapi.version>1.4.3</mailapi.version>
<metrics-core.version>3.1.2</metrics-core.version>
- <milo.version>2.22.1</milo.version>
<nekohtml.version>1.9.13</nekohtml.version>
<okhttp.version>3.13.1</okhttp.version>
<opennlp.version>1.9.0</opennlp.version>
@@ -92,10 +103,213 @@
<hawtbuf.version>1.11</hawtbuf.version>
<maven-shade-plugin.version>3.0.0</maven-shade-plugin.version>
+
+ <!-- Connect Dependencies-->
+ <animal-sniffer-annotations.version>1.17</animal-sniffer-annotations.version>
+ <bcprov.version>1.61</bcprov.version>
+ <checker-qual.version>2.5.2</checker-qual.version>
+ <commons-compress.version>1.18</commons-compress.version>
+ <commons-text.version>1.4</commons-text.version>
+ <errorprone-annotations.version>2.2.0</errorprone-annotations.version>
+ <java-websocket.version>1.4.0</java-websocket.version>
+ <javax-validation.version>2.0.1.Final</javax-validation.version>
+ <javax-websocket-client-api.version>1.1</javax-websocket-client-api.version>
+ <jsrosbridge.version>0.2.0</jsrosbridge.version>
+ <influxdb.java.version>2.14</influxdb.java.version>
+ <hadoop.version>3.2.1</hadoop.version>
+ <eclipse.milo.version>0.4.0</eclipse.milo.version>
+ <mysql-binlog-connector.version>0.18.1</mysql-binlog-connector.version>
+ <mysql-connector-java.version>8.0.15</mysql-connector-java.version>
+ <netty.version>4.1.39.Final</netty.version>
+ <nimbus-jose-jwt.version>4.41.1</nimbus-jose-jwt.version>
+ <opencsv.version>4.6</opencsv.version>
+ <plc4x.version>0.6.0</plc4x.version>
+ <protobuf.version>3.6.1</protobuf.version>
+ <pulsar.version>2.5.1</pulsar.version>
+ <slack.version>1.2.0</slack.version>
</properties>
<dependencyManagement>
<dependencies>
+ <!-- External Connect dependencies -->
+ <dependency>
+ <groupId>org.codehaus.mojo</groupId>
+ <artifactId>animal-sniffer-annotations</artifactId>
+ <version>${animal-sniffer-annotations.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.bouncycastle</groupId>
+ <artifactId>bcprov-jdk15on</artifactId>
+ <version>${bcprov.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.checkerframework</groupId>
+ <artifactId>checker-qual</artifactId>
+ <version>${checker-qual.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.commons</groupId>
+ <artifactId>commons-compress</artifactId>
+ <version>${commons-compress.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.commons</groupId>
+ <artifactId>commons-text</artifactId>
+ <version>${commons-text.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.java-websocket</groupId>
+ <artifactId>Java-WebSocket</artifactId>
+ <version>${java-websocket.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>javax.websocket</groupId>
+ <artifactId>javax.websocket-api</artifactId>
+ <version>${javax-websocket-client-api.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>edu.wpi.rail</groupId>
+ <artifactId>jrosbridge</artifactId>
+ <version>${jsrosbridge.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.influxdb</groupId>
+ <artifactId>influxdb-java</artifactId>
+ <version>${influxdb.java.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.hadoop</groupId>
+ <artifactId>hadoop-client</artifactId>
+ <version>${hadoop.version}</version>
+ <exclusions>
+ <exclusion>
+ <artifactId>jetty-server</artifactId>
+ <groupId>org.eclipse.jetty</groupId>
+ </exclusion>
+ <exclusion>
+ <artifactId>jetty-servlet</artifactId>
+ <groupId>org.eclipse.jetty</groupId>
+ </exclusion>
+ <exclusion>
+ <artifactId>jetty-servlets</artifactId>
+ <groupId>org.eclipse.jetty</groupId>
+ </exclusion>
+ <exclusion>
+ <artifactId>jetty-webapp</artifactId>
+ <groupId>org.eclipse.jetty</groupId>
+ </exclusion>
+ <exclusion>
+ <artifactId>jetty-util</artifactId>
+ <groupId>org.eclipse.jetty</groupId>
+ </exclusion>
+ <exclusion>
+ <groupId>com.sun.jersey</groupId>
+ <artifactId>jersey-core</artifactId>
+ </exclusion>
+ <exclusion>
+ <groupId>com.sun.jersey</groupId>
+ <artifactId>jersey-client</artifactId>
+ </exclusion>
+ <exclusion>
+ <groupId>com.sun.jersey</groupId>
+ <artifactId>jersey-servlet</artifactId>
+ </exclusion>
+ </exclusions>
+ </dependency>
+ <dependency>
+ <groupId>org.eclipse.milo</groupId>
+ <artifactId>sdk-client</artifactId>
+ <version>${eclipse.milo.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>com.github.shyiko</groupId>
+ <artifactId>mysql-binlog-connector-java</artifactId>
+ <version>${mysql-binlog-connector.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>mysql</groupId>
+ <artifactId>mysql-connector-java</artifactId>
+ <version>${mysql-connector-java.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>io.netty</groupId>
+ <artifactId>netty-buffer</artifactId>
+ <version>${netty.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>io.netty</groupId>
+ <artifactId>netty-codec</artifactId>
+ <version>${netty.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>io.netty</groupId>
+ <artifactId>netty-common</artifactId>
+ <version>${netty.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>io.netty</groupId>
+ <artifactId>netty-transport</artifactId>
+ <version>${netty.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>com.nimbusds</groupId>
+ <artifactId>nimbus-jose-jwt</artifactId>
+ <version>${nimbus-jose-jwt.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>com.opencsv</groupId>
+ <artifactId>opencsv</artifactId>
+ <version>${opencsv.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.plc4x</groupId>
+ <artifactId>plc4j-api</artifactId>
+ <version>${plc4x.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.plc4x</groupId>
+ <artifactId>plc4j-driver-s7</artifactId>
+ <version>${plc4x.version}</version>
+ <scope>runtime</scope>
+ </dependency>
+ <dependency>
+ <groupId>com.google.protobuf</groupId>
+ <artifactId>protobuf-java</artifactId>
+ <version>${protobuf.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.apache.pulsar</groupId>
+ <artifactId>pulsar-client</artifactId>
+ <version>${pulsar.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>com.ullink.slack</groupId>
+ <artifactId>simpleslackapi</artifactId>
+ <version>${slack.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>com.google.errorprone</groupId>
+ <artifactId>error_prone_annotations</artifactId>
+ <version>${errorprone-annotations.version}</version>
+ </dependency>
+
+ <dependency>
+ <groupId>com.fasterxml.jackson.module</groupId>
+ <artifactId>jackson-module-jaxb-annotations</artifactId>
+ <version>${jackson.version}</version>
+ </dependency>
+ <dependency>
+ <groupId>org.glassfish.jersey.media</groupId>
+ <artifactId>jersey-media-sse</artifactId>
+ <version>${jersey.version}</version>
+ <exclusions>
+ <exclusion>
+ <groupId>org.glassfish.jersey.core</groupId>
+ <artifactId>jersey-server</artifactId>
+ </exclusion>
+ </exclusions>
+ </dependency>
+
<!-- StreamPipes dependencies -->
<dependency>
<groupId>org.apache.streampipes</groupId>
@@ -235,11 +449,6 @@
<version>${nekohtml.version}</version>
</dependency>
<dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-milo</artifactId>
- <version>${milo.version}</version>
- </dependency>
- <dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-math3</artifactId>
<version>${commons-math3.version}</version>
@@ -347,6 +556,7 @@
+
<!-- Test dependencies -->
<dependency>
<groupId>junit</groupId>
diff --git a/streampipes-connect-adapters/pom.xml b/streampipes-connect-adapters/pom.xml
index b7f79c5..8c50250 100644
--- a/streampipes-connect-adapters/pom.xml
+++ b/streampipes-connect-adapters/pom.xml
@@ -30,31 +30,6 @@
<packaging>pom</packaging>
- <properties>
- <animal-sniffer-annotations.version>1.17</animal-sniffer-annotations.version>
- <bcprov.version>1.61</bcprov.version>
- <checker-qual.version>2.5.2</checker-qual.version>
- <commons-compress.version>1.18</commons-compress.version>
- <commons-text.version>1.4</commons-text.version>
- <errorprone-annotations.version>2.2.0</errorprone-annotations.version>
- <java-websocket.version>1.4.0</java-websocket.version>
- <javax-validation.version>2.0.1.Final</javax-validation.version>
- <javax-websocket-client-api.version>1.1</javax-websocket-client-api.version>
- <jsrosbridge.version>0.2.0</jsrosbridge.version>
- <influxdb.java.version>2.14</influxdb.java.version>
- <hadoop.version>3.2.1</hadoop.version>
- <milo.version>0.4.0</milo.version>
- <mysql-binlog-connector.version>0.18.1</mysql-binlog-connector.version>
- <mysql-connector-java.version>8.0.15</mysql-connector-java.version>
- <netty.version>4.1.39.Final</netty.version>
- <nimbus-jose-jwt.version>4.41.1</nimbus-jose-jwt.version>
- <okio.version>1.15.0</okio.version>
- <opencsv.version>4.6</opencsv.version>
- <plc4x.version>0.6.0</plc4x.version>
- <protobuf.version>3.6.1</protobuf.version>
- <pulsar.version>2.5.1</pulsar.version>
- <slack.version>1.2.0</slack.version>
- </properties>
<dependencies>
<!-- StreamPipes dependencies -->
@@ -68,67 +43,54 @@
<dependency>
<groupId>com.fasterxml.jackson.module</groupId>
<artifactId>jackson-module-jaxb-annotations</artifactId>
- <version>${jackson.version}</version>
</dependency>
<dependency>
<groupId>com.github.shyiko</groupId>
<artifactId>mysql-binlog-connector-java</artifactId>
- <version>${mysql-binlog-connector.version}</version>
</dependency>
<dependency>
<groupId>org.influxdb</groupId>
<artifactId>influxdb-java</artifactId>
- <version>${influxdb.java.version}</version>
</dependency>
<dependency>
<groupId>com.google.errorprone</groupId>
<artifactId>error_prone_annotations</artifactId>
- <version>${errorprone-annotations.version}</version>
</dependency>
<dependency>
<groupId>com.google.protobuf</groupId>
<artifactId>protobuf-java</artifactId>
- <version>${protobuf.version}</version>
</dependency>
<dependency>
<groupId>com.nimbusds</groupId>
<artifactId>nimbus-jose-jwt</artifactId>
- <version>${nimbus-jose-jwt.version}</version>
</dependency>
<dependency>
<groupId>com.opencsv</groupId>
<artifactId>opencsv</artifactId>
- <version>${opencsv.version}</version>
</dependency>
<dependency>
<groupId>com.ullink.slack</groupId>
<artifactId>simpleslackapi</artifactId>
- <version>${slack.version}</version>
</dependency>
<dependency>
<groupId>edu.wpi.rail</groupId>
<artifactId>jrosbridge</artifactId>
- <version>${jsrosbridge.version}</version>
</dependency>
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-buffer</artifactId>
- <version>${netty.version}</version>
</dependency>
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-codec</artifactId>
- <version>${netty.version}</version>
</dependency>
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-common</artifactId>
- <version>${netty.version}</version>
</dependency>
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-transport</artifactId>
- <version>${netty.version}</version>
</dependency>
<dependency>
<groupId>org.fusesource.mqtt-client</groupId>
@@ -137,12 +99,10 @@
<dependency>
<groupId>javax.websocket</groupId>
<artifactId>javax.websocket-api</artifactId>
- <version>${javax-websocket-client-api.version}</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
- <version>${mysql-connector-java.version}</version>
</dependency>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
@@ -151,17 +111,14 @@
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-compress</artifactId>
- <version>${commons-compress.version}</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-text</artifactId>
- <version>${commons-text.version}</version>
</dependency>
<dependency>
<groupId>org.apache.hadoop</groupId>
<artifactId>hadoop-client</artifactId>
- <version>${hadoop.version}</version>
<exclusions>
<exclusion>
<artifactId>jetty-server</artifactId>
@@ -200,43 +157,35 @@
<dependency>
<groupId>org.apache.plc4x</groupId>
<artifactId>plc4j-api</artifactId>
- <version>${plc4x.version}</version>
</dependency>
<dependency>
<groupId>org.apache.plc4x</groupId>
<artifactId>plc4j-driver-s7</artifactId>
- <version>${plc4x.version}</version>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>org.apache.pulsar</groupId>
<artifactId>pulsar-client</artifactId>
- <version>${pulsar.version}</version>
</dependency>
<dependency>
<groupId>org.bouncycastle</groupId>
<artifactId>bcprov-jdk15on</artifactId>
- <version>${bcprov.version}</version>
</dependency>
<dependency>
<groupId>org.checkerframework</groupId>
<artifactId>checker-qual</artifactId>
- <version>${checker-qual.version}</version>
</dependency>
<dependency>
<groupId>org.codehaus.mojo</groupId>
<artifactId>animal-sniffer-annotations</artifactId>
- <version>${animal-sniffer-annotations.version}</version>
</dependency>
<dependency>
<groupId>org.eclipse.milo</groupId>
<artifactId>sdk-client</artifactId>
- <version>${milo.version}</version>
</dependency>
<dependency>
<groupId>org.glassfish.jersey.media</groupId>
<artifactId>jersey-media-sse</artifactId>
- <version>${jersey.version}</version>
<exclusions>
<exclusion>
<groupId>org.glassfish.jersey.core</groupId>
@@ -247,14 +196,12 @@
<dependency>
<groupId>org.java-websocket</groupId>
<artifactId>Java-WebSocket</artifactId>
- <version>${java-websocket.version}</version>
</dependency>
<!-- Test dependencies -->
<dependency>
<groupId>com.github.tomakehurst</groupId>
<artifactId>wiremock</artifactId>
- <version>${wiremock.version}</version>
<scope>test</scope>
<exclusions>
<exclusion>
diff --git a/streampipes-sinks-databases-jvm/pom.xml b/streampipes-sinks-databases-jvm/pom.xml
index 6631d1b..6e911b0 100644
--- a/streampipes-sinks-databases-jvm/pom.xml
+++ b/streampipes-sinks-databases-jvm/pom.xml
@@ -88,8 +88,8 @@
<artifactId>iotdb-jdbc</artifactId>
</dependency>
<dependency>
- <groupId>org.apache.camel</groupId>
- <artifactId>camel-milo</artifactId>
+ <groupId>org.eclipse.milo</groupId>
+ <artifactId>sdk-client</artifactId>
</dependency>
<dependency>
<groupId>org.eclipse.ditto</groupId>
diff --git a/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/opcua/OpcUa.java b/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/opcua/OpcUa.java
index 871a6fb..e7db8cf 100644
--- a/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/opcua/OpcUa.java
+++ b/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/opcua/OpcUa.java
@@ -20,7 +20,7 @@ package org.apache.streampipes.sinks.databases.jvm.opcua;
import org.eclipse.milo.opcua.sdk.client.OpcUaClient;
import org.eclipse.milo.opcua.sdk.client.api.config.OpcUaClientConfig;
-import org.eclipse.milo.opcua.stack.client.UaTcpStackClient;
+import org.eclipse.milo.opcua.stack.client.DiscoveryClient;
import org.eclipse.milo.opcua.stack.core.security.SecurityPolicy;
import org.eclipse.milo.opcua.stack.core.types.builtin.*;
import org.eclipse.milo.opcua.stack.core.types.structured.EndpointDescription;
@@ -33,6 +33,7 @@ import org.apache.streampipes.wrapper.context.EventSinkRuntimeContext;
import org.apache.streampipes.wrapper.runtime.EventSink;
import java.util.Arrays;
+import java.util.List;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
@@ -61,15 +62,15 @@ public class OpcUa implements EventSink<OpcUaParameters> {
this.params = parameters;
- EndpointDescription[] endpoints;
+ List<EndpointDescription> endpoints;
try {
- endpoints = UaTcpStackClient.getEndpoints(serverUrl).get();
+// endpoints = UaTcpStackClient.getEndpoints(serverUrl).get();
+ endpoints = DiscoveryClient.getEndpoints(serverUrl).get();
- EndpointDescription endpoint = null;
-
- endpoint = Arrays.stream(endpoints)
- .filter(e -> e.getSecurityPolicyUri().equals(SecurityPolicy.None.getSecurityPolicyUri()))
+ EndpointDescription endpoint = endpoints
+ .stream()
+ .filter(e -> e.getSecurityPolicyUri().equals(SecurityPolicy.None.getUri()))
.findFirst().orElseThrow(() -> new Exception("no desired endpoints returned"));
OpcUaClientConfig config = OpcUaClientConfig.builder()
@@ -78,8 +79,7 @@ public class OpcUa implements EventSink<OpcUaParameters> {
.setEndpoint(endpoint)
.build();
- new OpcUaClient(config);
- opcUaClient = new OpcUaClient(config);
+ opcUaClient = OpcUaClient.create(config);
opcUaClient.connect().get();
} catch (Exception e) {