Fixed #2

crossid · Dec 5, 2020 · ac21651 · ac21651
1 parent 1d16087
commit ac21651
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/io/crossid/zeebe/exporter/ZeebeMongoClient.java b/src/main/java/io/crossid/zeebe/exporter/ZeebeMongoClient.java
@@ -222,7 +222,7 @@ private List<Tuple<String, UpdateOneModel<Document>>> handleWorkflowInstanceEven
         var timestamp = new Date(record.getTimestamp());
 
         var castRecord = (WorkflowInstanceRecordValue) record.getValue();
-        if (record.getKey() != castRecord.getWorkflowKey()) {
+        if (record.getKey() == castRecord.getWorkflowInstanceKey()) {
             result.add(workflowInstanceReplaceCommand(record, timestamp));
         }
         result.add(elementInstanceReplaceCommand(record, timestamp));
@@ -246,6 +246,7 @@ private Tuple<String, UpdateOneModel<Document>> workflowInstanceReplaceCommand(f
             document.append("parentElementInstanceKey", castRecord.getParentElementInstanceKey());
         }
 
+        System.out.println("Intent name: " + record.getIntent().name() + " Key: " + record.getKey() + " Workflow instance Key: " + castRecord.getWorkflowInstanceKey());
         switch (record.getIntent().name()) {
             case "ELEMENT_ACTIVATED":
                 document.append("state", "active").append("startTime", timestamp);