CORE-17386 - Create new topic for flow processor scheduled tasks. (#1271

) Create new topic for flow processor scheduled tasks.
corda · Sep 29, 2023 · c8bddf4 · c8bddf4
1 parent 4c8fcdf
commit c8bddf4
Show file tree

Hide file tree

Showing 3 changed files with 14 additions and 2 deletions.
diff --git a/data/topic-schema/src/main/java/net/corda/schema/Schemas.java b/data/topic-schema/src/main/java/net/corda/schema/Schemas.java
@@ -267,7 +267,13 @@ private VirtualNode() {
     public static final class ScheduledTask {
         private ScheduledTask() {}
 
+        // TODO - duplicated to ease migration from first to second. First can be removed once integrated with runtime-os
         public static final String SCHEDULED_TASK_DB_PROCESSOR = "scheduled.task.db.processor";
+        public static final String SCHEDULED_TASK_TOPIC_DB_PROCESSOR = "scheduled.task.db.processor";
+        public static final String SCHEDULED_TASK_NAME_DB_PROCESSOR = "deduplication-table-clean-up-task";
         public static final String SCHEDULED_TASK_MAPPER_PROCESSOR = "scheduled.task.mapper.processor";
+        public static final String SCHEDULED_TASK_TOPIC_FLOW_PROCESSOR = "scheduled.task.flow.processor";
+        public static final String SCHEDULED_TASK_NAME_SESSION_TIMEOUT = "flow-session-timout";
+
     }
 }
diff --git a/data/topic-schema/src/main/resources/net/corda/schema/ScheduledTask.yaml b/data/topic-schema/src/main/resources/net/corda/schema/ScheduledTask.yaml
@@ -11,3 +11,9 @@ topics:
       - flowMapper
     producers:
       - db
+  ScheduledTaskFlowProcessorTopic:
+    name: scheduled.task.flow.processor
+    consumers:
+      - flow
+    producers:
+      - db
diff --git a/data/topic-schema/src/test/kotlin/net/corda/schema/SchemaTests.kt b/data/topic-schema/src/test/kotlin/net/corda/schema/SchemaTests.kt
@@ -75,9 +75,9 @@ class SchemaTests {
         yamlFileData.forEach { (fileName: String, topics: Map<String, Map<String, *>>) ->
             println("Testing: $fileName")
             val potentialClass = fileName.substringBeforeLast(".")
-            val yamlTopicNames = topics["topics"]!!.toMap().map { it.value["name"] }
+            val yamlTopicNames = topics["topics"]!!.toMap().map { it.value["name"].toString() }
             val kotlinTopicNames = memberMap[potentialClass]
-            assertThat(yamlTopicNames).containsExactlyInAnyOrderElementsOf(kotlinTopicNames)
+            assertThat(kotlinTopicNames).containsAll(yamlTopicNames)
         }
     }
 }