This is an automated email from the ASF dual-hosted git repository. bossenti pushed a commit to branch dev in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git
commit d91ed205a2998d007381a4f01be9213744ea8dd3 Author: bossenti <[email protected]> AuthorDate: Tue Feb 16 15:09:58 2021 +0100 Fix error for connection via Host&Port --- .../connect/adapters/opcua/OpcUaAdapter.java | 18 ++++++++++++++---- 1 file changed, 14 insertions(+), 4 deletions(-) diff --git a/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/opcua/OpcUaAdapter.java b/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/opcua/OpcUaAdapter.java index b8d12e2..1c7c5a6 100644 --- a/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/opcua/OpcUaAdapter.java +++ b/streampipes-connect-adapters/src/main/java/org/apache/streampipes/connect/adapters/opcua/OpcUaAdapter.java @@ -251,16 +251,26 @@ public class OpcUaAdapter extends SpecificDataStreamAdapter { String selectedAlternativeConnection = extractor.selectedAlternativeInternalId(OPC_HOST_OR_URL); String selectedAlternativeAuthentication = extractor.selectedAlternativeInternalId(ACCESS_MODE); - String serverAddress = extractor.singleValueParameter(OPC_SERVER_URL, String.class); - if (!serverAddress.startsWith("opc.tcp://")) { - serverAddress = "opc.tcp://" + serverAddress; - }; + if (selectedAlternativeConnection.equals(OPC_URL)) { + String serverAddress = extractor.singleValueParameter(OPC_SERVER_URL, String.class); + + if (!serverAddress.startsWith("opc.tcp://")) { + serverAddress = "opc.tcp://" + serverAddress; + } + this.opcUaServer = serverAddress; this.selectedURL = true; } else { + + String serverAddress = extractor.singleValueParameter(OPC_SERVER_HOST, String.class); + + if (!serverAddress.startsWith("opc.tcp://")) { + serverAddress = "opc.tcp://" + serverAddress; + } + this.opcUaServer = serverAddress; this.port = extractor.singleValueParameter(OPC_SERVER_PORT, String.class); this.selectedURL = false;
