JavaEE Sample::Batch::Batch Schedule

ManagedScheduledBatchTest

The Batch specification does not offer anything to schedule jobs. However, the Java EE plataform offer a few ways that allow you to schedule Batch jobs.

Adding a Trigger to a ManagedScheduledExecutorService is possible to trigger an execution of the batch job by specifying the next execution date of the job.

@Stateless()
@Local(MyManagedScheduledBatch.class)
public class MyManagedScheduledBatchBean implements MyManagedScheduledBatch {

    public MyManagedScheduledBatchBean();
    @Resource()
    private ManagedScheduledExecutorService executor;

    @Override()
    public void runJob();

    public void runJob2();

    protected MyJob createJob();
}

We’re just going to deploy the application as a web archive. Note the inclusion of the following files:

/META-INF/batch-jobs/myJob.xml

The myJob.xml file is needed for running the batch definition. We are also adding an alternative bean to override the created batch instance do we can track it’s status and the modified batch instance.

Warning

MyJobAlternative not found

Warning

MyManagedScheduledBatchAlternative not found

@Deployment
public static WebArchive createDeployment() {
    BeansDescriptor beansXml = Descriptors.create(BeansDescriptor.class);

    WebArchive war = ShrinkWrap.create(WebArchive.class)
            .addClasses(
                    MyBatchlet.class,
                    MyJob.class,
                    MyJobAlternative.class,
                    MyManagedScheduledBatch.class,
                    MyManagedScheduledBatchBean.class,
                    MyManagedScheduledBatchAlternative.class)
            .addAsWebInfResource(
                    new StringAsset(beansXml.createAlternatives().clazz(
                            MyManagedScheduledBatchAlternative.class.getName()).up().exportAsString()),
                    beansXml.getDescriptorName())
            .addAsResource("META-INF/batch-jobs/myJob.xml");
    System.out.println(war.toString(true));
    return war;
}

The batch job is scheduled to execute each 15 seconds. We expect to run the batch instance exactly 3 times as defined in the CountDownLatch object. To validate the test expected behaviour we just need to check the Batch Status in the JobExecution object. We should get a COMPLETED for every execution.

@Test
public void testTimeScheduleBatch() throws Exception {
    managedScheduledBatch.runJob();

    MyJobAlternative.managedScheduledCountDownLatch.await(90, TimeUnit.SECONDS);

    assertEquals(0, MyJobAlternative.managedScheduledCountDownLatch.getCount());
    assertEquals(3, MyJob.executedBatchs.size());

    for (Long executedBatch : MyJob.executedBatchs) {
        assertEquals(BatchStatus.COMPLETED,
                BatchRuntime.getJobOperator().getJobExecution(executedBatch).getBatchStatus());
    }
}

TimerScheduleBatchTest

The Batch specification does not offer anything to schedule jobs. However, the Java EE plataform offer a few ways that allow you to schedule Batch jobs.

Annotating a method bean with Schedule, it’s possible to schedule an execution of a batch job by the specified cron expression in the Schedule annotation.

Warning

AbstractTimerBatch not found

@Startup()
@Singleton()
public class MyTimerScheduleBean extends AbstractTimerBatch {

    public MyTimerScheduleBean();
}

We’re just going to deploy the application as a web archive. Note the inclusion of the following files:

/META-INF/batch-jobs/myJob.xml

The myJob.xml file is needed for running the batch definition. We are also adding an alternative bean to override the batch schedule timeout and track the execution calls,

Warning

MyTimerScheduleAlternative not found

@Deployment
public static WebArchive createDeployment() {
    WebArchive war = ShrinkWrap.create(WebArchive.class)
            .addClasses(
                    MyBatchlet.class,
                    MyJob.class,
                    AbstractTimerBatch.class,
                    MyTimerScheduleAlternative.class)
            .addAsWebInfResource(EmptyAsset.INSTANCE, ArchivePaths.create("beans.xml"))
            .addAsResource("META-INF/batch-jobs/myJob.xml");

    System.out.println(war.toString(true));
    return war;
}

@Test
public void testTimeScheduleBatch() throws Exception {
    MyTimerScheduleAlternative.timerScheduleCountDownLatch.await(90, TimeUnit.SECONDS);

    assertEquals(0, MyTimerScheduleAlternative.timerScheduleCountDownLatch.getCount());
    assertEquals(3, MyTimerScheduleAlternative.executedBatchs.size());

    for (Long executedBatch : MyTimerScheduleAlternative.executedBatchs) {
        assertEquals(BatchStatus.COMPLETED,
                BatchRuntime.getJobOperator().getJobExecution(executedBatch).getBatchStatus());
    }
}

Batch Schedule

Scheduling a Batch Job

ManagedScheduledBatchTest

TimerScheduleBatchTest

Share the Knowledge

Help Improve

Recent Changelog