添加 Controller 类
代码如下：
@RestController
public class MyController {@Autowiredprivate ProcessRuntime processRuntime;@Autowiredprivate TaskRuntime taskRuntime;@Autowiredprivate SecurityUtil securityUtil;
}实现任务完成
@RequestMapping("testTask")public void testTask() {Page<Task> taskPage = taskRuntime.tasks(Pageable.of(0, 10));if (taskPage.getTotalItems() > 0) {for (Task task : taskPage.getContent()) {taskRuntime.claim(TaskPayloadBuilder.claim().withTaskId(task.getId()).build());System.out.println("任务：" + task);taskRuntime.complete(TaskPayloadBuilder.complete().withTaskId(task.getId()).build());}}Page<Task> taskPage2 = taskRuntime.tasks(Pageable.of(0, 10));if (taskPage2.getTotalItems() > 0) {System.out.println("任务：" + taskPage2.getContent());}}
编写 SpringBoot 启动类
@SpringBootApplication(exclude = SecurityAutoConfiguration.class)
public class ActvitiApplication {private Logger logger = LoggerFactory.getLogger(ActvitiApplication.class);public static void main(String[] args) {SpringApplication.run(ActvitiApplication.class, args);}@Beanpublic Connector testConnector() {return integrationContext -> {logger.info("我被调用啦~~");return integrationContext;};}
}
