Camunda SendTask和ReceiveTask

一：bpmn

二：java

@Service
public class SendTaskService implements JavaDelegate {
    @Autowired
    private RuntimeService runtimeService;

    @Override
    public void execute(DelegateExecution execution) throws Exception {
        runtimeService.createMessageCorrelation("receive_task_msg")
                .processInstanceBusinessKey("key001")
                .correlate();
    }
}

三：test

// 1.先启动接收
repositoryService.createDeployment().name("接收流程")
        .addClasspathResource("bpmn/receive_task.bpmn").deploy();
runtimeService.startProcessInstanceByKey("ReceiveTaskProces", "key001");

// 2.再发送
repositoryService.createDeployment().name("发送流程")
        .addClasspathResource("bpmn/send_task.bpmn").deploy();
runtimeService.startProcessInstanceByKey("SendTaskProcess", "key001");

四：db

1. 先启动接收流程，StartEvent -> ReceiveTask 会进入挂起等待状态。
2. 后启动发送流程，StartEvent -> SendTask -> UserTask。
3. 接收流程因收到发送流程的唤醒，所以接收流程也来到了UserTask。
4. 最终两个流程都进入到下一个节点UserTask。