(streampipes) branch dev updated: fix: Properly disconnect from OPC-UA in case of failure (#3707)

[riemer]

This is an automated email from the ASF dual-hosted git repository.

riemer 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 7e77a169e0 fix: Properly disconnect from OPC-UA in case of failure 
(#3707)
7e77a169e0 is described below

commit 7e77a169e0bbb21415742d58ba7e7a540bd18a68
Author: Dominik Riemer <dominik.rie...@gmail.com>
AuthorDate: Mon Jul 28 17:09:03 2025 +0200

    fix: Properly disconnect from OPC-UA in case of failure (#3707)
---
 .../extensions/connectors/opcua/client/SpOpcUaClient.java        | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git 
a/streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/client/SpOpcUaClient.java
 
b/streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/client/SpOpcUaClient.java
index 04a3f93998..c0a8787d65 100644
--- 
a/streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/client/SpOpcUaClient.java
+++ 
b/streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/client/SpOpcUaClient.java
@@ -53,7 +53,12 @@ public class SpOpcUaClient<T extends OpcUaConfig> {
     OpcUaClientConfig clientConfig = new 
MiloOpcUaConfigurationProvider().makeClientConfig(spOpcConfig);
     var client = OpcUaClient.create(clientConfig);
     client.addSessionInitializer(new DataTypeDictionarySessionInitializer(new 
GenericBsdParser()));
-    client.connect().get();
-    return new ConnectedOpcUaClient(client);
+    try {
+      client.connect().get();
+      return new ConnectedOpcUaClient(client);
+    } catch (Exception e) {
+      client.disconnect().get();
+      throw e;
+    }
   }
 }