java - 将自定义 Job 添加到 jobexecutor

Question

是否可以（如果可以：如何）在 camunda BPM 中向 jobexecutor 添加自定义作业？我的要求是通过 Timer 或 Loop 来执行一个流程相关的 Service。我不想直接在 BPMN 中对此进行建模，因为它实际上并不是流程的一部分。我可以启动仅包含一个异步服务任务的其他任意进程来实现这一点，但我更愿意直接将包含 SOAP/REST/RMI 调用的方法调用添加到作业队列，而不需要额外的努力。以前有人试过吗？

Answer 1

这是一个高级问题。可以使用内部 API 创建作业。你需要提供两件事：

自定义作业处理程序：

public class CustomjobHandler implements JobHandler {

  public static final String TYPE = "customjobHandler";

    public String getType() {
      return TYPE;
    }

    public void execute(String configuration, ExecutionEntity execution, CommandContext commandContext) {
      // provide custom job execution logic
    }    
}

作业处理程序被添加到流程引擎配置中。见（customJobHandlers列表）。

创建作业的命令

例如来自 Java 委托（您也可以使用自定义命令）。

public class CreateJobCommand implements Command<String> {

  public String execute(CommandContext commandContext) {

    MessageEntity message = new MessageEntity();
    message.setJobHandlerType(CustomJobHandler.TYPE);
    String config = "some string you want to pass to the hanlder";
    message.setJobHandlerConfiguration(config);

    Context
      .getCommandContext()
      .getJobManager()
      .send(message);

    return message.getId();
  }

}

这将创建一个尽快执行的“消息实体”。如果你想要一个定时执行，你可以创建一个 TimerEntity。然后就可以在流程引擎的命令执行器上执行命令了。

编辑：要在独立引擎中对此进行测试，您必须将 CustomJobHandler 添加到 camunda.cfg.xml：

<property name="customJobHandlers">
 <list>
   <bean class="<FQN of CustomJobHandler>" />
 </list>
</property>