这是可能的,但我想你也需要使用弹簧集成。 您需要设置整合到侦听JMX然后通过管道到通道,然后将一些requestTransformer被倾听:
public class SomethingToJobLaunchRequestTransformer extends AbstractSmthTransformer<JobLaunchRequest> {
private Job job;
public void setJob(Job job) {
this.job = job;
}
@Override
protected final JobLaunchRequest transformSomething(Something smt) {
JobParametersBuilder jobParametersBuilder = new JobParametersBuilder();
//put your something into job parameters....
return new JobLaunchRequest(job, jobParametersBuilder.toJobParameters());
}
}
最后把它传递给JobLaunchingGateway
欲了解更多详情请documentation,它包含很好的例子。