forked from camunda-community-hub/kafka-connect-zeebe
-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathprocess.bpmn
112 lines (112 loc) · 6.03 KB
/
process.bpmn
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
<?xml version="1.0" encoding="UTF-8"?>
<bpmn:definitions xmlns:bpmn="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:zeebe="http://camunda.org/schema/zeebe/1.0" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" id="Definitions_10l1fhd" targetNamespace="http://bpmn.io/schema/bpmn" exporter="Zeebe Modeler" exporterVersion="0.9.0">
<bpmn:process id="ping-pong" name="Ping Pong" isExecutable="true">
<bpmn:startEvent id="StartEvent_1" name="Wants to ping">
<bpmn:outgoing>SequenceFlow_01s5lf9</bpmn:outgoing>
</bpmn:startEvent>
<bpmn:serviceTask id="ServiceTask_1sx6rbe" name="To Kafka">
<bpmn:extensionElements>
<zeebe:taskDefinition type="ping" />
<zeebe:taskHeaders>
<zeebe:header key="topic" value="pong" />
</zeebe:taskHeaders>
</bpmn:extensionElements>
<bpmn:incoming>SequenceFlow_01s5lf9</bpmn:incoming>
<bpmn:outgoing>SequenceFlow_0980d1m</bpmn:outgoing>
</bpmn:serviceTask>
<bpmn:sequenceFlow id="SequenceFlow_01s5lf9" sourceRef="StartEvent_1" targetRef="ServiceTask_1sx6rbe" />
<bpmn:intermediateCatchEvent id="IntermediateCatchEvent_0iqm2ei" name="From Kafka">
<bpmn:incoming>SequenceFlow_0980d1m</bpmn:incoming>
<bpmn:outgoing>SequenceFlow_1ghzjh3</bpmn:outgoing>
<bpmn:messageEventDefinition messageRef="Message_19mpeg2" />
</bpmn:intermediateCatchEvent>
<bpmn:sequenceFlow id="SequenceFlow_0980d1m" name="Source connector completes the task after consuming the ping" sourceRef="ServiceTask_1sx6rbe" targetRef="IntermediateCatchEvent_0iqm2ei" />
<bpmn:endEvent id="EndEvent_07vkxen" name="Successfully pong'd">
<bpmn:incoming>SequenceFlow_1ghzjh3</bpmn:incoming>
</bpmn:endEvent>
<bpmn:sequenceFlow id="SequenceFlow_1ghzjh3" name="Sink connector publishes pong" sourceRef="IntermediateCatchEvent_0iqm2ei" targetRef="EndEvent_07vkxen" />
<bpmn:textAnnotation id="TextAnnotation_00v49jv">
<bpmn:text>Job Type: ping</bpmn:text>
</bpmn:textAnnotation>
<bpmn:textAnnotation id="TextAnnotation_07gk4bu">
<bpmn:text>Topic: pong</bpmn:text>
</bpmn:textAnnotation>
<bpmn:association id="Association_05vuc64" sourceRef="ServiceTask_1sx6rbe" targetRef="TextAnnotation_00v49jv" />
<bpmn:association id="Association_0zyz146" sourceRef="ServiceTask_1sx6rbe" targetRef="TextAnnotation_07gk4bu" />
<bpmn:textAnnotation id="TextAnnotation_1rhpbcu">
<bpmn:text>Correlation key: key</bpmn:text>
</bpmn:textAnnotation>
<bpmn:association id="Association_18k8qrv" sourceRef="IntermediateCatchEvent_0iqm2ei" targetRef="TextAnnotation_1rhpbcu" />
</bpmn:process>
<bpmn:message id="Message_19mpeg2" name="pong">
<bpmn:extensionElements>
<zeebe:subscription correlationKey="=key" />
</bpmn:extensionElements>
</bpmn:message>
<bpmndi:BPMNDiagram id="BPMNDiagram_1">
<bpmndi:BPMNPlane id="BPMNPlane_1" bpmnElement="ping-pong">
<bpmndi:BPMNEdge id="SequenceFlow_1ghzjh3_di" bpmnElement="SequenceFlow_1ghzjh3">
<di:waypoint x="653" y="182" />
<di:waypoint x="899" y="182" />
<bpmndi:BPMNLabel>
<dc:Bounds x="735" y="190" width="75" height="27" />
</bpmndi:BPMNLabel>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge id="SequenceFlow_0980d1m_di" bpmnElement="SequenceFlow_0980d1m">
<di:waypoint x="390" y="182" />
<di:waypoint x="617" y="182" />
<bpmndi:BPMNLabel>
<dc:Bounds x="445" y="189" width="88" height="66" />
</bpmndi:BPMNLabel>
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge id="SequenceFlow_01s5lf9_di" bpmnElement="SequenceFlow_01s5lf9">
<di:waypoint x="215" y="182" />
<di:waypoint x="290" y="182" />
</bpmndi:BPMNEdge>
<bpmndi:BPMNShape id="_BPMNShape_StartEvent_2" bpmnElement="StartEvent_1">
<dc:Bounds x="179" y="164" width="36" height="36" />
<bpmndi:BPMNLabel>
<dc:Bounds x="166" y="207" width="66" height="14" />
</bpmndi:BPMNLabel>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape id="ServiceTask_1sx6rbe_di" bpmnElement="ServiceTask_1sx6rbe">
<dc:Bounds x="290" y="142" width="100" height="80" />
</bpmndi:BPMNShape>
<bpmndi:BPMNShape id="IntermediateCatchEvent_0iqm2ei_di" bpmnElement="IntermediateCatchEvent_0iqm2ei">
<dc:Bounds x="617" y="164" width="36" height="36" />
<bpmndi:BPMNLabel>
<dc:Bounds x="609" y="207" width="57" height="14" />
</bpmndi:BPMNLabel>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape id="EndEvent_07vkxen_di" bpmnElement="EndEvent_07vkxen">
<dc:Bounds x="899" y="164" width="36" height="36" />
<bpmndi:BPMNLabel>
<dc:Bounds x="886" y="207" width="62" height="27" />
</bpmndi:BPMNLabel>
</bpmndi:BPMNShape>
<bpmndi:BPMNShape id="TextAnnotation_00v49jv_di" bpmnElement="TextAnnotation_00v49jv">
<dc:Bounds x="426" y="81" width="151" height="30" />
</bpmndi:BPMNShape>
<bpmndi:BPMNShape id="TextAnnotation_07gk4bu_di" bpmnElement="TextAnnotation_07gk4bu">
<dc:Bounds x="426" y="38" width="151" height="30" />
</bpmndi:BPMNShape>
<bpmndi:BPMNShape id="TextAnnotation_1rhpbcu_di" bpmnElement="TextAnnotation_1rhpbcu">
<dc:Bounds x="683" y="81" width="151" height="30" />
</bpmndi:BPMNShape>
<bpmndi:BPMNEdge id="Association_05vuc64_di" bpmnElement="Association_05vuc64">
<di:waypoint x="340" y="142" />
<di:waypoint x="340" y="96" />
<di:waypoint x="426" y="96" />
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge id="Association_0zyz146_di" bpmnElement="Association_0zyz146">
<di:waypoint x="340" y="142" />
<di:waypoint x="340" y="53" />
<di:waypoint x="426" y="53" />
</bpmndi:BPMNEdge>
<bpmndi:BPMNEdge id="Association_18k8qrv_di" bpmnElement="Association_18k8qrv">
<di:waypoint x="650" y="172" />
<di:waypoint x="737" y="111" />
</bpmndi:BPMNEdge>
</bpmndi:BPMNPlane>
</bpmndi:BPMNDiagram>
</bpmn:definitions>