New topics for Flow Topology changes. (#1280)

Author: Dries Samyn

data/topic-schema/src/main/java/net/corda/schema/Schemas.java

@@ -105,6 +105,11 @@ private Flow() {
         public static final String FLOW_MAPPER_EVENT_DLQ_TOPIC = getDLQTopic(FLOW_MAPPER_EVENT_TOPIC);
         public static final String FLOW_MAPPER_CLEANUP_TOPIC = "flow.mapper.cleanup";
         public static final String FLOW_TIMEOUT_TOPIC = "flow.timeout";
+        public static final String FLOW_MAPPER_START = "flow.mapper.start";
+        public static final String FLOW_MAPPER_SESSION_OUT = "flow.mapper.session.out";
+        public static final String FLOW_MAPPER_SESSION_IN = "flow.mapper.session.in";
+        public static final String FLOW_START = "flow.start";
+        public static final String FLOW_SESSION = "flow.session";
     }
 
     /**

data/topic-schema/src/main/resources/net/corda/schema/Flow.yaml

@@ -94,3 +94,39 @@ topics:
     producers:
       - flow
     config:
+  FlowMapperStart:
+    name: flow.mapper.start
+    consumers:
+      - flowMapper
+    producers:
+      - rest
+    config:
+  FlowMapperSessionOut:
+    name: flow.mapper.session.out
+    consumers:
+      - flowMapper
+    producers:
+      - flow
+    config:
+  FlowMapperSessionIn:
+    name: flow.mapper.session.in
+    consumers:
+      - flowMapper
+    producers:
+      - link-manager
+    config:
+  FlowStart:
+    name: flow.start
+    consumers:
+      - flow
+    producers:
+      - flowMapper
+    config:
+  FlowSession:
+    name: flow.session
+    consumers:
+      - flow
+    producers:
+      - flowMapper
+    config:
+