feat: set the process instance key when a timer triggered (#309)

camunda-community-hub · Dec 3, 2022 · 1142d41 · 1142d41
1 parent 11af7a4
commit 1142d41
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/data/src/main/kotlin/io/zeebe/zeeqs/data/entity/Timer.kt b/data/src/main/kotlin/io/zeebe/zeeqs/data/entity/Timer.kt
@@ -12,7 +12,7 @@ class Timer(
     val dueDate: Long,
     var repetitions: Int,
     val elementId: String,
-    val processInstanceKey: Long?,
+    var processInstanceKey: Long?,
     val elementInstanceKey: Long?,
     val processDefinitionKey: Long?
 ) {

diff --git a/hazelcast-importer/src/main/kotlin/io/zeebe/zeeqs/importer/hazelcast/HazelcastImporter.kt b/hazelcast-importer/src/main/kotlin/io/zeebe/zeeqs/importer/hazelcast/HazelcastImporter.kt
@@ -419,6 +419,7 @@ class HazelcastImporter(
             "TRIGGERED" -> {
                 entity.state = TimerState.TRIGGERED
                 entity.endTime = record.metadata.timestamp
+                entity.processInstanceKey = record.processInstanceKey
             }
             "CANCELED" -> {
                 entity.state = TimerState.CANCELED