in src/main/java/org/apache/sling/jobs/it/services/JobManagerTestComponent.java [50:64]
public void activate(Map<String,Object> props) {
for( int i = 0; i < 10; i++) {
Job job = jobManager.newJobBuilder(Types.jobQueue(TOPIC), Types.jobType(AsyncJobConsumer.JOB_TYPE)).addProperties(
Collections.singletonMap("jobtest", (Object) "jobtest")).add();
assertNotNull(job);
LOGGER.info("Started Job {} ", job.getId());
}
// then start 10 sync jobs.
for( int i = 0; i < 10; i++) {
Job job = jobManager.newJobBuilder(Types.jobQueue(TOPIC), Types.jobType(FullySyncJob.JOB_TYPE))
.addProperties(Collections.singletonMap("jobtest", (Object) "jobtest")).add();
assertNotNull(job);
LOGGER.info("Started Job {} ", job.getId());
}
}