diff --git a/nifi-opcua-nar/pom.xml b/nifi-opcua-nar/pom.xml index dad6aab..b96484d 100644 --- a/nifi-opcua-nar/pom.xml +++ b/nifi-opcua-nar/pom.xml @@ -25,6 +25,9 @@ nifi-opcua-nar 1.0 nar + + nifi-opcua + true true diff --git a/nifi-opcua-service/src/main/java/de/fraunhofer/fit/opcua/StandardOPCUAService.java b/nifi-opcua-service/src/main/java/de/fraunhofer/fit/opcua/StandardOPCUAService.java index c7a71db..314837c 100644 --- a/nifi-opcua-service/src/main/java/de/fraunhofer/fit/opcua/StandardOPCUAService.java +++ b/nifi-opcua-service/src/main/java/de/fraunhofer/fit/opcua/StandardOPCUAService.java @@ -112,10 +112,10 @@ public void onEnabled(final ConfigurationContext context) throws InitializationE EndpointDescription endpointDescription = null; for (EndpointDescription ed : endpoints) { - + getLogger().info("Endpoint: " + ed.getEndpointUrl() + " security: " + ed.getSecurityPolicyUri()); if (ed.getSecurityPolicyUri().equals(securityPolicy)) { endpointDescription = ed; - getLogger().debug("Connecting to endpoint " + ed.getEndpointUrl() + getLogger().info("Connecting to endpoint " + ed.getEndpointUrl() + " with security policy " + ed.getSecurityPolicyUri()); } } @@ -126,7 +126,7 @@ public void onEnabled(final ConfigurationContext context) throws InitializationE } OpcUaClientConfigBuilder cfg = new OpcUaClientConfigBuilder(); - cfg.setEndpoint(endpoints[0]); + cfg.setEndpoint(endpointDescription); opcClient = new OpcUaClient(cfg.build()); opcClient.connect().get();