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/streampipes.git
The following commit(s) were added to refs/heads/dev by this push:
new 152862830f fix: Mark old mqtt based adapters as deprecated for future
removal (#3900)
152862830f is described below
commit 152862830ff40c097eb81e8b87363b43f91ace8f
Author: Philipp Zehnder <[email protected]>
AuthorDate: Tue Nov 11 14:07:40 2025 +0100
fix: Mark old mqtt based adapters as deprecated for future removal (#3900)
---
.../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";
