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

zehnder pushed a commit to branch fork/dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git

commit 19ade2bdd5761e0ac9df63fc47f6c1d04abef02d
Author: Philipp Zehnder <[email protected]>
AuthorDate: Mon Jan 29 10:56:41 2024 +0100

    fix(#2144): Set default static property values for adapter instance
---
 .../connectors/opcua/migration/OpcUaAdapterMigrationV2.java           | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git 
a/streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/migration/OpcUaAdapterMigrationV2.java
 
b/streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/migration/OpcUaAdapterMigrationV2.java
index 4336287aab..58fa91b652 100644
--- 
a/streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/migration/OpcUaAdapterMigrationV2.java
+++ 
b/streampipes-extensions/streampipes-connectors-opcua/src/main/java/org/apache/streampipes/extensions/connectors/opcua/migration/OpcUaAdapterMigrationV2.java
@@ -20,8 +20,6 @@ package 
org.apache.streampipes.extensions.connectors.opcua.migration;
 
 import 
org.apache.streampipes.extensions.api.extractor.IStaticPropertyExtractor;
 import org.apache.streampipes.extensions.api.migration.IAdapterMigrator;
-import org.apache.streampipes.extensions.connectors.opcua.config.OpcUaConfig;
-import 
org.apache.streampipes.extensions.connectors.opcua.config.SpOpcUaConfigExtractor;
 import org.apache.streampipes.extensions.connectors.opcua.utils.OpcUaUtil;
 import org.apache.streampipes.model.connect.adapter.AdapterDescription;
 import org.apache.streampipes.model.extensions.svcdiscovery.SpServiceTagPrefix;
@@ -58,7 +56,7 @@ public class OpcUaAdapterMigrationV2 implements 
IAdapterMigrator {
                                                      IStaticPropertyExtractor 
extractor) throws RuntimeException {
     var newConfigs = element.getConfig().stream().map(config->{
       if (isHostOrUrlConfig(config)){
-        var alternatives = modifiedAlternatives();
+        var alternatives = modifiedAlternatives(extractor);
         alternatives.setIndex(config.getIndex());
         return alternatives;
       } else {

Reply via email to