[incubator-streampipes-extensions] branch dev updated: fixed bug in OpcUaAdapter

[ze...@apache.org]

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

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


The following commit(s) were added to refs/heads/dev by this push:
     new 9966791  fixed bug in OpcUaAdapter
     new 339577d  Merge pull request #29 from chrweiss/dev
9966791 is described below

commit 996679116cf204ec395dafc07002cf78fdbb7665
Author: weichr <Ch...@iosb.fraunhofer.de>
AuthorDate: Fri Aug 7 16:43:23 2020 +0200

    fixed bug in OpcUaAdapter
---
 .../apache/streampipes/connect/adapters/opcua/OpcUaAdapter.java   | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

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 80f393b..0820535 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
@@ -18,6 +18,7 @@
 
 package org.apache.streampipes.connect.adapters.opcua;
 
+import com.github.jsonldjava.utils.Obj;
 import org.apache.streampipes.connect.adapter.Adapter;
 import org.apache.streampipes.connect.adapter.exception.AdapterException;
 import org.apache.streampipes.connect.adapter.exception.ParseException;
@@ -116,7 +117,12 @@ public class OpcUaAdapter extends SpecificDataStreamAdapter {
 
         // ensure that event is complete and all opc ua subscriptions transmitted at least one value
         if (event.keySet().size() >= this.numberProperties) {
-            adapterPipeline.process(event);
+            Map <String, Object> newEvent = new HashMap<>();
+            // deep copy of event to prevent preprocessor error
+            for (String k : event.keySet()) {
+              newEvent.put(k, event.get(k));
+            }
+            adapterPipeline.process(newEvent);
         }
     }