adding a new sample to schedule Batch Jobs

arun-gupta · arun-gupta · commit 95447257ce01 · 2014-07-08T09:01:18.000-07:00
diff --git a/batch/pom.xml b/batch/pom.xml
@@ -29,5 +29,6 @@
         <module>multiple-steps</module>
         <module>split</module>
         <module>chunk-simple-nobeans</module>
+        <module>scheduling</module>
     </modules>
 </project>
diff --git a/batch/scheduling/pom.xml b/batch/scheduling/pom.xml
@@ -0,0 +1,23 @@
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+
+    <modelVersion>4.0.0</modelVersion>
+    <parent>
+        <groupId>org.javaee7.batch</groupId>
+        <artifactId>batch-samples</artifactId>
+        <version>1.0-SNAPSHOT</version>
+        <relativePath>../pom.xml</relativePath>
+    </parent>
+
+    <artifactId>scheduling</artifactId>
+    <packaging>war</packaging>
+    <name>Batch Schedule</name>
+    <description>Scheduling a Batch Job</description>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.javaee7</groupId>
+            <artifactId>util-samples</artifactId>
+        </dependency>
+    </dependencies>
+</project>
diff --git a/batch/scheduling/src/main/java/org/samples/wildfly/scheduling/batch/MyJob.java b/batch/scheduling/src/main/java/org/samples/wildfly/scheduling/batch/MyJob.java
@@ -0,0 +1,15 @@
+package org.samples.wildfly.scheduling.batch;
+
+import java.util.Properties;
+import javax.batch.runtime.BatchRuntime;
+
+/**
+ * @author arungupta
+ */
+public class MyJob implements Runnable {
+
+    public void run() {
+        BatchRuntime.getJobOperator().start("myJob", new Properties());
+    }
+    
+}
diff --git a/batch/scheduling/src/main/java/org/samples/wildfly/scheduling/batch/MySingletonEJB.java b/batch/scheduling/src/main/java/org/samples/wildfly/scheduling/batch/MySingletonEJB.java
@@ -0,0 +1,17 @@
+package org.samples.wildfly.scheduling.batch;
+
+import java.util.Properties;
+import javax.batch.runtime.BatchRuntime;
+import javax.ejb.Schedule;
+import javax.ejb.Singleton;
+
+/**
+ * @author arungupta
+ */
+@Singleton
+public class MySingletonEJB {
+    @Schedule(hour = "23", minute = "59", second = "59")
+    public void myJob() {
+        BatchRuntime.getJobOperator().start("myJob", new Properties());
+    }
+}
diff --git a/batch/scheduling/src/main/java/org/samples/wildfly/scheduling/batch/MyStatelessEJB.java b/batch/scheduling/src/main/java/org/samples/wildfly/scheduling/batch/MyStatelessEJB.java
@@ -0,0 +1,46 @@
+package org.samples.wildfly.scheduling.batch;
+
+import java.util.Calendar;
+import java.util.Date;
+import java.util.concurrent.TimeUnit;
+import javax.annotation.Resource;
+import javax.ejb.Stateless;
+import javax.enterprise.concurrent.LastExecution;
+import javax.enterprise.concurrent.ManagedScheduledExecutorService;
+import javax.enterprise.concurrent.Trigger;
+
+/**
+ * @author arungupta
+ */
+@Stateless
+public class MyStatelessEJB {
+    @Resource
+    ManagedScheduledExecutorService executor;
+    
+    public void runJob() {
+        executor.schedule(new MyJob(), new Trigger() {
+
+            @Override
+            public Date getNextRunTime(LastExecution lastExecutionInfo, Date taskScheduledTime) {
+                Calendar cal = Calendar.getInstance();
+                cal.setTime(taskScheduledTime);
+                cal.add(Calendar.DATE, 1);
+                return cal.getTime();
+            }
+
+            @Override
+            public boolean skipRun(LastExecution lastExecutionInfo, Date scheduledRunTime) {
+                return null == lastExecutionInfo;
+            }
+            
+        });
+    }
+    
+    public void cancelJob() {
+        executor.shutdown();
+    }
+    
+    public void runJob2() {
+        executor.scheduleWithFixedDelay(new MyJob(), 1, 2, TimeUnit.MINUTES);
+    }
+}
diff --git a/batch/scheduling/src/main/webapp/index.html b/batch/scheduling/src/main/webapp/index.html
@@ -0,0 +1,10 @@
+<!DOCTYPE html>
+<html>
+    <head>
+        <title>Start Page</title>
+        <meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
+    </head>
+    <body>
+        <h1>Hello World!</h1>
+    </body>
+</html>
