This is an automated email from the ASF dual-hosted git repository. bossenti pushed a commit to branch refactor-version-adapter in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit 60de88bc7231e9778474034f5ac2a28e34c2aede Author: bossenti <[email protected]> AuthorDate: Sun Nov 19 13:32:55 2023 +0100 refactor: add value for version parameter in adapter description --- .../streampipes/connect/iiot/adapters/iolink/IfmAlMqttAdapter.java | 2 +- .../streampipes/connect/iiot/adapters/ros/RosBridgeAdapter.java | 2 +- .../iiot/adapters/simulator/machine/MachineDataSimulatorAdapter.java | 2 +- .../streampipes/connect/iiot/protocol/stream/FileReplayAdapter.java | 2 +- .../streampipes/connect/iiot/protocol/stream/HttpServerProtocol.java | 2 +- .../streampipes/connect/iiot/protocol/stream/HttpStreamProtocol.java | 2 +- .../streampipes/connect/adapters/image/stream/ImageStreamAdapter.java | 2 +- .../java/org/apache/streampipes/connect/adapters/iss/IssAdapter.java | 2 +- .../apache/streampipes/connect/adapters/netio/NetioMQTTAdapter.java | 2 +- .../apache/streampipes/connect/adapters/netio/NetioRestAdapter.java | 2 +- .../extensions/connectors/influx/adapter/InfluxDbStreamAdapter.java | 2 +- .../extensions/connectors/kafka/adapter/KafkaProtocol.java | 2 +- .../streampipes/extensions/connectors/mqtt/adapter/MqttProtocol.java | 2 +- .../streampipes/extensions/connectors/nats/adapter/NatsProtocol.java | 2 +- .../streampipes/extensions/connectors/opcua/adapter/OpcUaAdapter.java | 2 +- .../extensions/connectors/plc/adapter/modbus/Plc4xModbusAdapter.java | 4 ++-- .../extensions/connectors/pulsar/adapter/PulsarProtocol.java | 2 +- .../extensions/connectors/rocketmq/adapter/RocketMQProtocol.java | 2 +- .../extensions/connectors/tubemq/adapter/TubeMQProtocol.java | 2 +- 19 files changed, 20 insertions(+), 20 deletions(-) diff --git a/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/iolink/IfmAlMqttAdapter.java b/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/iolink/IfmAlMqttAdapter.java index 5a0648112..9c9fc05ca 100644 --- a/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/iolink/IfmAlMqttAdapter.java +++ b/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/iolink/IfmAlMqttAdapter.java @@ -77,7 +77,7 @@ public class IfmAlMqttAdapter implements StreamPipesAdapter { @Override public IAdapterConfiguration declareConfig() { return AdapterConfigurationBuilder - .create(ID, IfmAlMqttAdapter::new) + .create(ID, 0, IfmAlMqttAdapter::new) .withLocales(Locales.EN) .withAssets(Assets.DOCUMENTATION, Assets.ICON) .withCategory(AdapterType.Generic, AdapterType.Manufacturing) diff --git a/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/ros/RosBridgeAdapter.java b/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/ros/RosBridgeAdapter.java index c86ea31ab..675461ecb 100644 --- a/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/ros/RosBridgeAdapter.java +++ b/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/ros/RosBridgeAdapter.java @@ -92,7 +92,7 @@ public class RosBridgeAdapter implements StreamPipesAdapter, ResolvesContainerPr @Override public IAdapterConfiguration declareConfig() { - return AdapterConfigurationBuilder.create(ID, RosBridgeAdapter::new) + return AdapterConfigurationBuilder.create(ID, 0, RosBridgeAdapter::new) .withLocales(Locales.EN) .withAssets(Assets.DOCUMENTATION, Assets.ICON) .withCategory(AdapterType.Manufacturing) diff --git a/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/simulator/machine/MachineDataSimulatorAdapter.java b/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/simulator/machine/MachineDataSimulatorAdapter.java index bef53062c..2af0b55e1 100644 --- a/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/simulator/machine/MachineDataSimulatorAdapter.java +++ b/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/adapters/simulator/machine/MachineDataSimulatorAdapter.java @@ -43,7 +43,7 @@ public class MachineDataSimulatorAdapter implements StreamPipesAdapter { @Override public IAdapterConfiguration declareConfig() { - return AdapterConfigurationBuilder.create(ID, MachineDataSimulatorAdapter::new) + return AdapterConfigurationBuilder.create(ID, 0, MachineDataSimulatorAdapter::new) .withAssets(Assets.DOCUMENTATION, Assets.ICON) .withLocales(Locales.EN) .withCategory(AdapterType.Debugging) diff --git a/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/FileReplayAdapter.java b/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/FileReplayAdapter.java index f9ad62a2c..744982a88 100644 --- a/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/FileReplayAdapter.java +++ b/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/FileReplayAdapter.java @@ -80,7 +80,7 @@ public class FileReplayAdapter implements StreamPipesAdapter { @Override public IAdapterConfiguration declareConfig() { - return AdapterConfigurationBuilder.create(ID, FileReplayAdapter::new) + return AdapterConfigurationBuilder.create(ID, 0, FileReplayAdapter::new) .withSupportedParsers( new JsonParsers(), new CsvParser(), diff --git a/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/HttpServerProtocol.java b/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/HttpServerProtocol.java index 5fc242cc1..c068e3159 100644 --- a/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/HttpServerProtocol.java +++ b/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/HttpServerProtocol.java @@ -103,7 +103,7 @@ public class HttpServerProtocol implements StreamPipesAdapter { @Override public IAdapterConfiguration declareConfig() { return AdapterConfigurationBuilder - .create(ID, HttpServerProtocol::new) + .create(ID, 0, HttpServerProtocol::new) .withSupportedParsers(Parsers.defaultParsers()) .withLocales(Locales.EN) .withAssets(Assets.DOCUMENTATION, Assets.ICON) diff --git a/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/HttpStreamProtocol.java b/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/HttpStreamProtocol.java index ade3d66cb..376f20f29 100644 --- a/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/HttpStreamProtocol.java +++ b/streampipes-extensions/streampipes-connect-adapters-iiot/src/main/java/org/apache/streampipes/connect/iiot/protocol/stream/HttpStreamProtocol.java @@ -106,7 +106,7 @@ public class HttpStreamProtocol implements StreamPipesAdapter, IPullAdapter { @Override public IAdapterConfiguration declareConfig() { return AdapterConfigurationBuilder - .create(ID, HttpStreamProtocol::new) + .create(ID, 0, HttpStreamProtocol::new) .withSupportedParsers(Parsers.defaultParsers()) .withAssets(Assets.DOCUMENTATION, Assets.ICON) .withLocales(Locales.EN) diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/image/stream/ImageStreamAdapter.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/image/stream/ImageStreamAdapter.java index 52758308d..405afdc1c 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/image/stream/ImageStreamAdapter.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/image/stream/ImageStreamAdapter.java @@ -46,7 +46,7 @@ public class ImageStreamAdapter implements StreamPipesAdapter { @Override public IAdapterConfiguration declareConfig() { - return AdapterConfigurationBuilder.create(ID, ImageStreamAdapter::new) + return AdapterConfigurationBuilder.create(ID, 0, ImageStreamAdapter::new) .withLocales(Locales.EN) .withAssets(Assets.DOCUMENTATION, Assets.ICON) .requiredIntegerParameter(Labels.withId(ImageZipUtils.INTERVAL_KEY)) diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/iss/IssAdapter.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/iss/IssAdapter.java index b2d53617a..8c7b1d46b 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/iss/IssAdapter.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/iss/IssAdapter.java @@ -103,7 +103,7 @@ public class IssAdapter implements StreamPipesAdapter, IPullAdapter { @Override public IAdapterConfiguration declareConfig() { - return AdapterConfigurationBuilder.create(ID, IssAdapter::new) + return AdapterConfigurationBuilder.create(ID, 0,IssAdapter::new) .withLocales(Locales.EN) .withAssets(Assets.DOCUMENTATION, Assets.ICON) .withCategory(AdapterType.OpenData) diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/netio/NetioMQTTAdapter.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/netio/NetioMQTTAdapter.java index a9edfc5cf..421105783 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/netio/NetioMQTTAdapter.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/netio/NetioMQTTAdapter.java @@ -53,7 +53,7 @@ public class NetioMQTTAdapter implements StreamPipesAdapter { @Override public IAdapterConfiguration declareConfig() { - return AdapterConfigurationBuilder.create(ID, NetioMQTTAdapter::new) + return AdapterConfigurationBuilder.create(ID, 0, NetioMQTTAdapter::new) .withLocales(Locales.EN) .withAssets(Assets.DOCUMENTATION, Assets.ICON) .withCategory(AdapterType.Energy) diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/netio/NetioRestAdapter.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/netio/NetioRestAdapter.java index 998115bc5..20989d98f 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/netio/NetioRestAdapter.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/netio/NetioRestAdapter.java @@ -125,7 +125,7 @@ public class NetioRestAdapter implements StreamPipesAdapter, IPullAdapter { @Override public IAdapterConfiguration declareConfig() { - return AdapterConfigurationBuilder.create(ID, NetioRestAdapter::new) + return AdapterConfigurationBuilder.create(ID, 0, NetioRestAdapter::new) .withLocales(Locales.EN) .withAssets(Assets.DOCUMENTATION, Assets.ICON) .withCategory(AdapterType.Energy) diff --git a/streampipes-extensions/streampipes-connectors-influx/src/main/java/org/apache/streampipes/extensions/connectors/influx/adapter/InfluxDbStreamAdapter.java b/streampipes-extensions/streampipes-connectors-influx/src/main/java/org/apache/streampipes/extensions/connectors/influx/adapter/InfluxDbStreamAdapter.java index 8c9ff2375..495edc282 100644 --- a/streampipes-extensions/streampipes-connectors-influx/src/main/java/org/apache/streampipes/extensions/connectors/influx/adapter/InfluxDbStreamAdapter.java +++ b/streampipes-extensions/streampipes-connectors-influx/src/main/java/org/apache/streampipes/extensions/connectors/influx/adapter/InfluxDbStreamAdapter.java @@ -57,7 +57,7 @@ public class InfluxDbStreamAdapter implements StreamPipesAdapter { @Override public IAdapterConfiguration declareConfig() { - var builder = AdapterConfigurationBuilder.create(ID, InfluxDbStreamAdapter::new) + var builder = AdapterConfigurationBuilder.create(ID, 0, InfluxDbStreamAdapter::new) .withAssets(Assets.DOCUMENTATION, Assets.ICON) .withLocales(Locales.EN); diff --git a/streampipes-extensions/streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/adapter/KafkaProtocol.java b/streampipes-extensions/streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/adapter/KafkaProtocol.java index f8b0340d5..e7df3dcc1 100644 --- a/streampipes-extensions/streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/adapter/KafkaProtocol.java +++ b/streampipes-extensions/streampipes-connectors-kafka/src/main/java/org/apache/streampipes/extensions/connectors/kafka/adapter/KafkaProtocol.java @@ -145,7 +145,7 @@ public class KafkaProtocol implements StreamPipesAdapter, SupportsRuntimeConfig latestAlternative.setSelected(true); return AdapterConfigurationBuilder - .create(ID, KafkaProtocol::new) + .create(ID, 0, KafkaProtocol::new) .withSupportedParsers(Parsers.defaultParsers()) .withAssets(Assets.DOCUMENTATION, Assets.ICON) .withLocales(Locales.EN) diff --git a/streampipes-extensions/streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/adapter/MqttProtocol.java b/streampipes-extensions/streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/adapter/MqttProtocol.java index b27f2205f..1399794a8 100644 --- a/streampipes-extensions/streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/adapter/MqttProtocol.java +++ b/streampipes-extensions/streampipes-connectors-mqtt/src/main/java/org/apache/streampipes/extensions/connectors/mqtt/adapter/MqttProtocol.java @@ -60,7 +60,7 @@ public class MqttProtocol implements StreamPipesAdapter { @Override public IAdapterConfiguration declareConfig() { return AdapterConfigurationBuilder - .create(ID, MqttProtocol::new) + .create(ID, 0, MqttProtocol::new) .withSupportedParsers(Parsers.defaultParsers()) .withLocales(Locales.EN) .withAssets(Assets.DOCUMENTATION, Assets.ICON) diff --git a/streampipes-extensions/streampipes-connectors-nats/src/main/java/org/apache/streampipes/extensions/connectors/nats/adapter/NatsProtocol.java b/streampipes-extensions/streampipes-connectors-nats/src/main/java/org/apache/streampipes/extensions/connectors/nats/adapter/NatsProtocol.java index 5be237458..6cbb2a07a 100644 --- a/streampipes-extensions/streampipes-connectors-nats/src/main/java/org/apache/streampipes/extensions/connectors/nats/adapter/NatsProtocol.java +++ b/streampipes-extensions/streampipes-connectors-nats/src/main/java/org/apache/streampipes/extensions/connectors/nats/adapter/NatsProtocol.java @@ -108,7 +108,7 @@ public class NatsProtocol implements StreamPipesAdapter { @Override public IAdapterConfiguration declareConfig() { return AdapterConfigurationBuilder - .create(ID, NatsProtocol::new) + .create(ID, 0, NatsProtocol::new) .withSupportedParsers(Parsers.defaultParsers()) .withCategory(AdapterType.Generic) .withLocales(Locales.EN) diff --git a/streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/adapter/OpcUaAdapter.java b/streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/adapter/OpcUaAdapter.java index 5df4f6329..6af0bd28f 100644 --- a/streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/adapter/OpcUaAdapter.java +++ b/streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/adapter/OpcUaAdapter.java @@ -143,7 +143,7 @@ public class OpcUaAdapter implements StreamPipesAdapter, IPullAdapter, SupportsR boolean emptyValueReceived = false; List<DataValue> returnValues = response.get(this.getPollingInterval().value(), this.getPollingInterval().timeUnit()); - if (returnValues.size() == 0) { + if (returnValues.isEmpty()) { emptyValueReceived = true; LOG.warn("Empty value object returned - event will not be sent"); } else { diff --git a/streampipes-extensions/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/adapter/modbus/Plc4xModbusAdapter.java b/streampipes-extensions/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/adapter/modbus/Plc4xModbusAdapter.java index 6938ead54..1487c77ae 100644 --- a/streampipes-extensions/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/adapter/modbus/Plc4xModbusAdapter.java +++ b/streampipes-extensions/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/adapter/modbus/Plc4xModbusAdapter.java @@ -266,14 +266,14 @@ public class Plc4xModbusAdapter implements StreamPipesAdapter, IPullAdapter { } /** - * Describe the adapter adapter and define what user inputs are required. Currently users can just select one node, + * Describe the adapter and define what user inputs are required. Currently users can just select one node, * this will be extended in the future * * @return description of adapter */ @Override public IAdapterConfiguration declareConfig() { - return AdapterConfigurationBuilder.create(ID, Plc4xModbusAdapter::new) + return AdapterConfigurationBuilder.create(ID, 0, Plc4xModbusAdapter::new) .withLocales(Locales.EN) .withAssets(Assets.DOCUMENTATION, Assets.ICON) .withCategory(AdapterType.Manufacturing) diff --git a/streampipes-extensions/streampipes-connectors-pulsar/src/main/java/org/apache/streampipes/extensions/connectors/pulsar/adapter/PulsarProtocol.java b/streampipes-extensions/streampipes-connectors-pulsar/src/main/java/org/apache/streampipes/extensions/connectors/pulsar/adapter/PulsarProtocol.java index 04ea26dea..c22567564 100644 --- a/streampipes-extensions/streampipes-connectors-pulsar/src/main/java/org/apache/streampipes/extensions/connectors/pulsar/adapter/PulsarProtocol.java +++ b/streampipes-extensions/streampipes-connectors-pulsar/src/main/java/org/apache/streampipes/extensions/connectors/pulsar/adapter/PulsarProtocol.java @@ -94,7 +94,7 @@ public class PulsarProtocol implements StreamPipesAdapter, SupportsRuntimeConfig @Override public IAdapterConfiguration declareConfig() { return AdapterConfigurationBuilder - .create(ID, PulsarProtocol::new) + .create(ID, 0, PulsarProtocol::new) .withSupportedParsers(Parsers.defaultParsers()) .withAssets(Assets.DOCUMENTATION, Assets.ICON) .withLocales(Locales.EN) diff --git a/streampipes-extensions/streampipes-connectors-rocketmq/src/main/java/org/apache/streampipes/extensions/connectors/rocketmq/adapter/RocketMQProtocol.java b/streampipes-extensions/streampipes-connectors-rocketmq/src/main/java/org/apache/streampipes/extensions/connectors/rocketmq/adapter/RocketMQProtocol.java index 02970e363..adedfbab3 100644 --- a/streampipes-extensions/streampipes-connectors-rocketmq/src/main/java/org/apache/streampipes/extensions/connectors/rocketmq/adapter/RocketMQProtocol.java +++ b/streampipes-extensions/streampipes-connectors-rocketmq/src/main/java/org/apache/streampipes/extensions/connectors/rocketmq/adapter/RocketMQProtocol.java @@ -73,7 +73,7 @@ public class RocketMQProtocol implements StreamPipesAdapter { @Override public IAdapterConfiguration declareConfig() { return AdapterConfigurationBuilder - .create(ID, RocketMQProtocol::new) + .create(ID, 0, RocketMQProtocol::new) .withSupportedParsers(Parsers.defaultParsers()) .withAssets(Assets.DOCUMENTATION, Assets.ICON) .withLocales(Locales.EN) diff --git a/streampipes-extensions/streampipes-connectors-tubemq/src/main/java/org/apache/streampipes/extensions/connectors/tubemq/adapter/TubeMQProtocol.java b/streampipes-extensions/streampipes-connectors-tubemq/src/main/java/org/apache/streampipes/extensions/connectors/tubemq/adapter/TubeMQProtocol.java index 84ed9b828..8fe027fe9 100644 --- a/streampipes-extensions/streampipes-connectors-tubemq/src/main/java/org/apache/streampipes/extensions/connectors/tubemq/adapter/TubeMQProtocol.java +++ b/streampipes-extensions/streampipes-connectors-tubemq/src/main/java/org/apache/streampipes/extensions/connectors/tubemq/adapter/TubeMQProtocol.java @@ -102,7 +102,7 @@ public class TubeMQProtocol implements StreamPipesAdapter { @Override public IAdapterConfiguration declareConfig() { return AdapterConfigurationBuilder - .create(ID, TubeMQProtocol::new) + .create(ID, 0, TubeMQProtocol::new) .withSupportedParsers(Parsers.defaultParsers()) .withAssets(Assets.DOCUMENTATION, Assets.ICON) .withLocales(Locales.EN)
