ComplexFlow.java

    engine.getRepositoryService().createDeployment() //
      .addModelInstance("order.bpmn", Bpmn.createProcess("order").executable() //
        .startEvent()
        .serviceTask().name("A")
        .parallelGateway("fork1")
          .serviceTask().name("B")
          .parallelGateway("join2")
          .moveToNode("fork1")
          .serviceTask().name("C")
          .parallelGateway("fork2")
          .serviceTask().name("D")
          .parallelGateway("join1")
          .moveToNode("fork2")
          .serviceTask().name("E")
          .connectTo("join1")
        .connectTo("join2")
        .endEvent()
        .done()
      ).deploy();