This is an automated email from the ASF dual-hosted git repository. zehnder pushed a commit to branch deprecate-old-adapters in repository https://gitbox.apache.org/repos/asf/streampipes.git
commit 1b7a95229a5ba870261a2d006a441b91584e6356 Author: Philipp Zehnder <[email protected]> AuthorDate: Tue Nov 11 13:30:25 2025 +0100 fix: Mark old mqtt based adapters as deprecated for future removal --- .../streampipes/connect/iiot/adapters/iolink/IfmAlMqttAdapter.java | 1 + .../org/apache/streampipes/connect/adapters/netio/NetioMQTTAdapter.java | 1 + .../org/apache/streampipes/connect/adapters/netio/NetioRestAdapter.java | 1 + .../java/org/apache/streampipes/connect/adapters/netio/NetioUtils.java | 1 + 4 files changed, 4 insertions(+) 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 7729dbba96..e86862a48b 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 @@ -50,6 +50,7 @@ import java.io.InputStream; import java.util.List; import java.util.Map; +@Deprecated(since = "0.98.0", forRemoval = true) public class IfmAlMqttAdapter implements StreamPipesAdapter { public static final String ID = "org.apache.streampipes.connect.iiot.adapters.iolink"; 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 a697fcc5d4..4eb63b3fca 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 @@ -42,6 +42,7 @@ import java.util.ArrayList; import java.util.List; import java.util.Map; +@Deprecated(since = "0.98.0", forRemoval = true) public class NetioMQTTAdapter implements StreamPipesAdapter { private MqttConsumer mqttConsumer; 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 a58aa054c1..1e9a5ca306 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 @@ -51,6 +51,7 @@ import java.io.IOException; import java.util.Map; import java.util.concurrent.TimeUnit; +@Deprecated(since = "0.98.0", forRemoval = true) public class NetioRestAdapter implements StreamPipesAdapter, IPullAdapter { /** diff --git a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/netio/NetioUtils.java b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/netio/NetioUtils.java index a56c608ea5..cf6b7bd9f5 100644 --- a/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/netio/NetioUtils.java +++ b/streampipes-extensions/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/netio/NetioUtils.java @@ -34,6 +34,7 @@ import java.util.HashMap; import java.util.List; import java.util.Map; +@Deprecated(since = "0.98.0", forRemoval = true) public class NetioUtils { public static final String TIMESTAMP_KEY = "timestamp"; public static final String NAME_KEY = "name";
