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 23257ffba9 fix(#3893): Fix handle failing plc read (#3899)
23257ffba9 is described below
commit 23257ffba9217f3236b31e65869cb8071d692f2e
Author: Philipp Zehnder <[email protected]>
AuthorDate: Mon Nov 10 17:24:17 2025 +0100
fix(#3893): Fix handle failing plc read (#3899)
---
.../plc/adapter/generic/connection/ContinuousPlcRequestReader.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/streampipes-extensions/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/adapter/generic/connection/ContinuousPlcRequestReader.java
b/streampipes-extensions/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/adapter/generic/connection/ContinuousPlcRequestReader.java
index 7306ead5a5..3d04ad6312 100644
---
a/streampipes-extensions/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/adapter/generic/connection/ContinuousPlcRequestReader.java
+++
b/streampipes-extensions/streampipes-connectors-plc/src/main/java/org/apache/streampipes/extensions/connectors/plc/adapter/generic/connection/ContinuousPlcRequestReader.java
@@ -22,12 +22,12 @@ import
org.apache.streampipes.extensions.api.connect.IEventCollector;
import org.apache.streampipes.extensions.api.connect.IPollingSettings;
import org.apache.streampipes.extensions.api.connect.IPullAdapter;
import
org.apache.streampipes.extensions.connectors.plc.adapter.generic.model.Plc4xConnectionSettings;
+import
org.apache.streampipes.extensions.connectors.plc.cache.SpCachedPlcConnectionManager;
import
org.apache.streampipes.extensions.management.connect.adapter.util.PollingSettings;
import org.apache.plc4x.java.api.PlcConnection;
import org.apache.plc4x.java.api.PlcConnectionManager;
import org.apache.plc4x.java.api.messages.PlcReadResponse;
-import org.apache.plc4x.java.utils.cache.CachedPlcConnectionManager;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -84,8 +84,8 @@ public class ContinuousPlcRequestReader
private void handleFailingPlcRead(String problem) {
// ensure that the cached connection manager removes the broken connection
- if (connectionManager instanceof CachedPlcConnectionManager) {
- ((CachedPlcConnectionManager)
connectionManager).removeCachedConnection(settings.connectionString());
+ if (connectionManager instanceof SpCachedPlcConnectionManager) {
+ ((SpCachedPlcConnectionManager)
connectionManager).removeCachedConnection(settings.connectionString());
}
// Increase backoff counter on failure
