318.5. 例子
触发 Spring Batch 任务执行:
from("direct:startBatch").to("spring-batch:myJob");
from("direct:startBatch").to("spring-batch:myJob");
使用 JobLauncher 设置来触发 Spring Batch 作业执行。
from("direct:startBatch").to("spring-batch:myJob?jobLauncherRef=myJobLauncher");
from("direct:startBatch").to("spring-batch:myJob?jobLauncherRef=myJobLauncher");
从 JobLauncher 返回的 Camel 2.11.1 JobExecution 实例开始,由 SpringBatchProducer 作为输出消息转发。您可以使用 JobExecution 实例直接使用 Spring Batch API 执行一些操作。
from("direct:startBatch").to("spring-batch:myJob").to("mock:JobExecutions");
...
MockEndpoint mockEndpoint = ...;
JobExecution jobExecution = mockEndpoint.getExchanges().get(0).getIn().getBody(JobExecution.class);
BatchStatus currentJobStatus = jobExecution.getStatus();
from("direct:startBatch").to("spring-batch:myJob").to("mock:JobExecutions");
...
MockEndpoint mockEndpoint = ...;
JobExecution jobExecution = mockEndpoint.getExchanges().get(0).getIn().getBody(JobExecution.class);
BatchStatus currentJobStatus = jobExecution.getStatus();