Create new topic for flow processor scheduled tasks.

corda · Sep 29, 2023 · 071a5b7 · 071a5b7
1 parent 4c8fcdf
commit 071a5b7
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 0 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
@@ -269,5 +269,6 @@ private ScheduledTask() {}
 
         public static final String SCHEDULED_TASK_DB_PROCESSOR = "scheduled.task.db.processor";
         public static final String SCHEDULED_TASK_MAPPER_PROCESSOR = "scheduled.task.mapper.processor";
+        public static final String SCHEDULED_TASK_FLOW_PROCESSOR = "scheduled.task.flow.processor";
     }
 }
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