To create simple BPMN processes we provide a fluent builder API. With this API you can easily create basicprocesses in a few lines of code. In the generate process fluent api quickstart wedemonstrate how to create a rather complex process with 5 tasks and 2 gateways within less than 50 lines of code.

The fluent builder API is not nearly complete but provides you with the following basic elements:

  • process
  • start event
  • exclusive gateway
  • parallel gateway
  • script task
  • service task
  • user task
  • signal event definition
  • end event
  • subprocess

    Create a Process With the Fluent Builder API

To create an empty model instance with a new process the method Bpmn.createProcess() is used. After this,you can add as many tasks and gateways as you like. At the end you must call done() to return the generatedmodel instance. For example, a simple process with one user task can be created like this:

  1. BpmnModelInstance modelInstance = Bpmn.createProcess()
  2.   .startEvent()
  3.   .userTask()
  4.   .endEvent()
  5.   .done();

To add a new element you have to call a function which is named like theelement to add. Additionally you can set attributes of the last createdelement.

For example, let’s set the name of the process and mark it as executable and also give the user task a name.

  1. BpmnModelInstance modelInstance = Bpmn.createProcess()
  2.     .name("Example process")
  3.     .executable()
  4.   .startEvent()
  5.   .userTask()
  6.     .name("Some work to do")
  7.   .endEvent()
  8.   .done();

As you can see, a sequential process is really simple and straightforward to model, but often you wantbranches and a parallel execution path, which is also possible with the fluent builder API. Just adda parallel or exclusive gateway and model the first path till an end event or another gateway. After that,call the moveToLastGateway() method and you return to the last gateway and can model the next path.

  1. BpmnModelInstance modelInstance = Bpmn.createProcess()
  2.   .startEvent()
  3.   .userTask()
  4.   .parallelGateway()
  5.     .scriptTask()
  6.     .endEvent()
  7.   .moveToLastGateway()
  8.     .serviceTask()
  9.     .endEvent()
  10.   .done();

This example models a process with a user task after the start event followed by a parallel gatewaywith two parallel outgoing execution paths, each with a task and an end event.

Normally you want to add conditions on outgoing flows of an exclusive gateway which is also simple withthe fluent builder API. Just use the method condition() and give it a label and an expression.

  1. BpmnModelInstance modelInstance = Bpmn.createProcess()
  2.   .startEvent()
  3.   .userTask()
  4.   .exclusiveGateway()
  5.   .name("What to do next?")
  6.     .condition("Call an agent", "#{action = 'call'}")
  7.     .scriptTask()
  8.     .endEvent()
  9.   .moveToLastGateway()
  10.     .condition("Create a task", "#{action = 'task'}")
  11.     .serviceTask()
  12.     .endEvent()
  13.   .done();

If you want to use the moveToLastGateway() method but have multiple incomingsequence flows at your current position, you have to use the genericmoveToNode method with the id of the gateway. This could for example happenif you add a join gateway to your process. For this purpose and for loops, weadded the connectTo(elementId) method.

  1. BpmnModelInstance modelInstance = Bpmn.createProcess()
  2.   .startEvent()
  3.   .userTask()
  4.   .parallelGateway("fork")
  5.     .serviceTask()
  6.     .parallelGateway("join")
  7.   .moveToNode("fork")
  8.     .userTask()
  9.     .connectTo("join")
  10.   .moveToNode("fork")
  11.     .scriptTask()
  12.     .connectTo("join")
  13.   .endEvent()
  14.   .done()

This example creates a process with three parallel execution paths which alljoin in the second gateway. Notice that the first call of moveToNode is notnecessary, because at this point the joining gateway only has one incoming sequenceflow, but was used for consistency.

  1. BpmnModelInstance modelInstance = Bpmn.createProcess()
  2.   .startEvent()
  3.   .userTask()
  4.   .id("question")
  5.   .exclusiveGateway()
  6.   .name("Everything fine?")
  7.     .condition("yes", "#{fine}")
  8.     .serviceTask()
  9.     .userTask()
  10.     .endEvent()
  11.   .moveToLastGateway()
  12.     .condition("no", "#{!fine}")
  13.     .userTask()
  14.     .connectTo("question")
  15.   .done()

This example creates a parallel gateway with a feedback loop in the second execution path.

To create an embedded subprocess with the fluent builder API, you can directly add it to yourprocess building or you can detach it and create flow elements of the subprocess later on.

  1. // Directly define the subprocess
  2. BpmnModelInstance modelInstance = Bpmn.createProcess()
  3.   .startEvent()
  4.   .subProcess()
  5.     .camundaAsync()
  6.     .embeddedSubProcess()
  7.       .startEvent()
  8.       .userTask()
  9.       .endEvent()
  10.     .subProcessDone()
  11.   .serviceTask()
  12.   .endEvent()
  13.   .done();
  15. // Detach the subprocess building
  16. modelInstance = Bpmn.createProcess()
  17.   .startEvent()
  18.   .subProcess("subProcess")
  19.   .serviceTask()
  20.   .endEvent()
  21.   .done();
  23. SubProcess subProcess = (SubProcess) modelInstance.getModelElementById("subProcess");
  24. subProcess.builder()
  25.   .camundaAsync()
  26.   .embeddedSubProcess()
  27.     .startEvent()
  28.     .userTask()
  29.     .endEvent();

The example below shows how to create a throwing signal event definition and define the payload that this signal will contain. By using the camundaIn methods, it is possible to define which process variables will be included in the signal payload, define an expression that will be resolved in the signal-catching process instances, or declare that all of the process variables in the signal-throwing process instance should be passed. It is also possible to define a business key that will be assigned to the signal-catching process instances.

  1. BpmnModelInstance modelInstance = Bpmn.createProcess()
  2.   .startEvent()
  3.   .intermediateThrowEvent("throw")
  4.     .signalEventDefinition("signal")
  5.       .camundaInSourceTarget("source", "target1")
  6.       .camundaInSourceExpressionTarget("${'sourceExpression'}", "target2")
  7.       .camundaInAllVariables("all", true)
  8.       .camundaInBusinessKey("aBusinessKey")
  9.       .throwEventDefinitionDone()
  10.   .endEvent()
  11.   .done();

Extend a Process With the Fluent Builder API

With the fluent builder API you can not only create processes, you can also extend existing processes.

For example, imagine a process containing a parallel gateway with the id gateway. You now want toadd another execution path to it for a new service task which has to be executed every time.

  1. BpmnModelInstance modelInstance = Bpmn.readModelFromFile(new File("PATH/TO/MODEL.bpmn"));
  2. ParallelGateway gateway = (ParallelGateway) modelInstance.getModelElementById("gateway");
  4. gateway.builder()
  5.   .serviceTask()
  6.     .name("New task")
  7.   .endEvent();

Another use case is to insert new tasks between existing elements. Imagine a processcontaining a user task with the id task1 which is followed by a service task. And nowyou want to add a script task and a user task between these two.

  1. BpmnModelInstance modelInstance = Bpmn.readModelFromFile(new File("PATH/TO/MODEL.bpmn"));
  2. UserTask userTask = (UserTask) modelInstance.getModelElementById("task1");
  3. SequenceFlow outgoingSequenceFlow = userTask.getOutgoing().iterator().next();
  4. FlowNode serviceTask = outgoingSequenceFlow.getTarget();
  5. userTask.getOutgoing().remove(outgoingSequenceFlow);
  7. userTask.builder()
  8.   .scriptTask()
  9.   .userTask()
  10.   .connectTo(serviceTask.getId());

Generation of Diagram Interchange

To render the process, BPMN diagram elements are necessary. The fluent builder generatesBPMN Shapes and BPMN Edges and places them automatically for flow nodes and sequence flows.

  1. final BpmnModelInstance myProcess = Bpmn.createExecutableProcess("process-payments")
  2.       .startEvent()
  3.       .serviceTask()
  4.           .name("Process Payment")
  5.       .endEvent()
  6.       .done();
  8. System.out.println(Bpmn.convertToString(myProcess));

This example creates a BPMN containing both semantic elements (e.g., service task etc.) and diagram elements:

  1. <?xml version="1.0" encoding="UTF-8" standalone="no"?>
  2. <definitions xmlns:bpmndi="http://www.omg.org/spec/BPMN/20100524/DI" xmlns:camunda="http://camunda.org/schema/1.0/bpmn" xmlns:dc="http://www.omg.org/spec/DD/20100524/DC" xmlns:di="http://www.omg.org/spec/DD/20100524/DI" id="definitions_dfb1f18e-6034-448e-abae-0eb2f41469da" targetNamespace="http://www.omg.org/spec/BPMN/20100524/MODEL" xmlns="http://www.omg.org/spec/BPMN/20100524/MODEL">
  4.   <!-- Generated BPMN Semantic Elements -->
  5.   <process id="process-payments" isExecutable="true">
  6.     <startEvent id="startEvent_2b0abd37-75a9-47dd-9838-63f1390d7515">
  7.       <outgoing>sequenceFlow_b1eec5b5-889d-4e75-854d-59768fbdc8a2</outgoing>
  8.     </startEvent>
  9.     <serviceTask id="serviceTask_f4c2413f-5b26-49e8-b71c-2603e469ce09" name="Process Payment">
  10.       <incoming>sequenceFlow_b1eec5b5-889d-4e75-854d-59768fbdc8a2</incoming>
  11.       <outgoing>sequenceFlow_5839394a-c0c2-4a5b-aa81-9412f169cc35</outgoing>
  12.     </serviceTask>
  13.     <sequenceFlow id="sequenceFlow_b1eec5b5-889d-4e75-854d-59768fbdc8a2" sourceRef="startEvent_2b0abd37-75a9-47dd-9838-63f1390d7515" targetRef="serviceTask_f4c2413f-5b26-49e8-b71c-2603e469ce09"/>
  14.     <endEvent id="endEvent_8087f927-a53b-4126-95fc-c057736f3b73">
  15.       <incoming>sequenceFlow_5839394a-c0c2-4a5b-aa81-9412f169cc35</incoming>
  16.     </endEvent>
  17.     <sequenceFlow id="sequenceFlow_5839394a-c0c2-4a5b-aa81-9412f169cc35" sourceRef="serviceTask_f4c2413f-5b26-49e8-b71c-2603e469ce09" targetRef="endEvent_8087f927-a53b-4126-95fc-c057736f3b73"/>
  18.   </process>
  20.   <!-- Generated Diagram Elements -->
  21.   <bpmndi:BPMNDiagram id="BPMNDiagram_5b66dfb7-097b-4610-9681-43abb3ff97da">
  22.     <bpmndi:BPMNPlane bpmnElement="process-payments" id="BPMNPlane_ad88b4cf-9d7a-4b86-8386-f8db23ff388d">
  23.       <bpmndi:BPMNShape bpmnElement="startEvent_2b0abd37-75a9-47dd-9838-63f1390d7515" id="BPMNShape_d6c4e3c5-150c-43f7-adf8-1d388f466a69">
  24.         <dc:Bounds height="36.0" width="36.0" x="100.0" y="100.0"/>
  25.       </bpmndi:BPMNShape>
  26.       <bpmndi:BPMNShape bpmnElement="serviceTask_f4c2413f-5b26-49e8-b71c-2603e469ce09" id="BPMNShape_51006773-13df-4327-a4cf-a5952c39e86a">
  27.         <dc:Bounds height="80.0" width="100.0" x="186.0" y="78.0"/>
  28.       </bpmndi:BPMNShape>
  29.       <bpmndi:BPMNEdge bpmnElement="sequenceFlow_b1eec5b5-889d-4e75-854d-59768fbdc8a2" id="BPMNEdge_fb360594-8863-4d5d-b515-49e02a88d55d">
  30.         <di:waypoint x="136.0" y="118.0"/>
  31.         <di:waypoint x="186.0" y="118.0"/>
  32.       </bpmndi:BPMNEdge>
  33.       <bpmndi:BPMNShape bpmnElement="endEvent_8087f927-a53b-4126-95fc-c057736f3b73" id="BPMNShape_23930820-5507-45a0-8630-b5e45ee8dd4d">
  34.         <dc:Bounds height="36.0" width="36.0" x="336.0" y="100.0"/>
  35.       </bpmndi:BPMNShape>
  36.       <bpmndi:BPMNEdge bpmnElement="sequenceFlow_5839394a-c0c2-4a5b-aa81-9412f169cc35" id="BPMNEdge_07ed502e-069f-42a0-bd1b-fed0d68efbda">
  37.         <di:waypoint x="286.0" y="118.0"/>
  38.         <di:waypoint x="336.0" y="118.0"/>
  39.       </bpmndi:BPMNEdge>
  40.     </bpmndi:BPMNPlane>
  41.   </bpmndi:BPMNDiagram>
  42. </definitions>

The default behavior is that each newly added flow element will be placed next to the previous flow element.

When flow elements are added to an embedded subprocess, then the subprocess is resized when the subprocess border is reached. Therefore,it is recommended to first add all new elements to the subprocess and to then create the following elements. Otherwise it could lead tooverlapping elements in the diagram.

Branches of gateways are placed one below the other. Auto layout is not provided, therefore the elements of different branches may overlap.

原文: https://docs.camunda.org/manual/7.9/user-guide/model-api/bpmn-model-api/fluent-builder-api/