Skip to content

Commit 7e77a16

Browse files
fix: Properly disconnect from OPC-UA in case of failure (#3707)
1 parent bcc2eed commit 7e77a16

File tree

1 file changed

+7
-2
lines changed
  • streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/client

1 file changed

+7
-2
lines changed

streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/client/SpOpcUaClient.java

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -53,7 +53,12 @@ public ConnectedOpcUaClient connect()
5353
OpcUaClientConfig clientConfig = new MiloOpcUaConfigurationProvider().makeClientConfig(spOpcConfig);
5454
var client = OpcUaClient.create(clientConfig);
5555
client.addSessionInitializer(new DataTypeDictionarySessionInitializer(new GenericBsdParser()));
56-
client.connect().get();
57-
return new ConnectedOpcUaClient(client);
56+
try {
57+
client.connect().get();
58+
return new ConnectedOpcUaClient(client);
59+
} catch (Exception e) {
60+
client.disconnect().get();
61+
throw e;
62+
}
5863
}
5964
}

0 commit comments

Comments
 (0)