Merge branch 'master' of github.com:javaee-samples/javaee7-samples

Author: arun-gupta

batch/scheduling/pom.xml

@@ -16,8 +16,8 @@
 
     <dependencies>
         <dependency>
-            <groupId>org.javaee7</groupId>
-            <artifactId>util-samples</artifactId>
+            <groupId>org.jboss.shrinkwrap.descriptors</groupId>
+            <artifactId>shrinkwrap-descriptors-impl-javaee</artifactId>
         </dependency>
     </dependencies>
 </project>

batch/scheduling/src/main/java/org/javaee7/batch/samples/scheduling/AbstractTimerBatch.java

@@ -0,0 +1,22 @@
+package org.javaee7.batch.samples.scheduling;
+
+import javax.batch.runtime.BatchRuntime;
+import javax.ejb.Schedule;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Properties;
+
+/**
+ * @author Roberto Cortez
+ */
+public abstract class AbstractTimerBatch {
+    public static List<Long> executedBatchs = new ArrayList<>();
+
+    @Schedule(hour = "*", minute = "0", second = "0")
+    public void myJob() {
+        executedBatchs.add(BatchRuntime.getJobOperator().start("myJob", new Properties()));
+        afterRun();
+    }
+
+    protected void afterRun() {}
+}

batch/scheduling/src/main/java/org/javaee7/batch/samples/scheduling/MyBatchlet.java

@@ -0,0 +1,18 @@
+package org.javaee7.batch.samples.scheduling;
+
+import javax.batch.api.AbstractBatchlet;
+import javax.batch.runtime.BatchStatus;
+import javax.inject.Named;
+
+/**
+ * @author Roberto Cortez
+ */
+@Named
+public class MyBatchlet extends AbstractBatchlet {
+    @Override
+    public String process() {
+        System.out.println("Running inside a batchlet");
+
+        return BatchStatus.COMPLETED.toString();
+    }
+}

batch/scheduling/src/main/java/org/javaee7/batch/samples/scheduling/MyJob.java

@@ -0,0 +1,20 @@
+package org.javaee7.batch.samples.scheduling;
+
+import javax.batch.runtime.BatchRuntime;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Properties;
+
+/**
+ * @author arungupta
+ */
+public class MyJob implements Runnable {
+    public static List<Long> executedBatchs = new ArrayList<>();
+
+    public void run() {
+        executedBatchs.add(BatchRuntime.getJobOperator().start("myJob", new Properties()));
+        afterRun();
+    }
+
+    protected void afterRun() {}
+}

batch/scheduling/src/main/java/org/javaee7/batch/samples/scheduling/MyManagedScheduledBatch.java

@@ -0,0 +1,8 @@
+package org.javaee7.batch.samples.scheduling;
+
+/**
+ * @author Roberto Cortez
+ */
+public interface MyManagedScheduledBatch {
+    void runJob();
+}

batch/scheduling/src/main/java/org/javaee7/batch/samples/scheduling/MyManagedScheduledBatchBean.java

@@ -0,0 +1,71 @@
+package org.javaee7.batch.samples.scheduling;
+
+import javax.annotation.Resource;
+import javax.batch.runtime.BatchRuntime;
+import javax.batch.runtime.BatchStatus;
+import javax.ejb.Local;
+import javax.ejb.Stateless;
+import javax.enterprise.concurrent.LastExecution;
+import javax.enterprise.concurrent.ManagedScheduledExecutorService;
+import javax.enterprise.concurrent.Trigger;
+import java.util.Calendar;
+import java.util.Date;
+import java.util.List;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * @author arungupta
+ */
+@Stateless
+@Local(MyManagedScheduledBatch.class)
+public class MyManagedScheduledBatchBean implements MyManagedScheduledBatch {
+    @Resource
+    private ManagedScheduledExecutorService executor;
+
+    @Override
+    public void runJob() {
+        executor.schedule(createJob(), new Trigger() {
+
+            @Override
+            public Date getNextRunTime(LastExecution lastExecutionInfo, Date taskScheduledTime) {
+                if (MyJob.executedBatchs.size() >= 3) {
+                    return null;
+                }
+
+                Calendar cal = Calendar.getInstance();
+
+                if (lastExecutionInfo == null) {
+                    cal.setTime(taskScheduledTime);
+                } else {
+                    cal.setTime(lastExecutionInfo.getRunStart());
+                }
+
+                cal.add(Calendar.SECOND, 10);
+                return cal.getTime();
+            }
+
+            @Override
+            public boolean skipRun(LastExecution lastExecutionInfo, Date scheduledRunTime) {
+                List<Long> executedBatchs = MyJob.executedBatchs;
+
+                for (Long executedBatch : executedBatchs) {
+                    if (!BatchRuntime.getJobOperator().getJobExecution(executedBatch).getBatchStatus().equals(
+                            BatchStatus.COMPLETED)) {
+                        return true;
+                    }
+                }
+
+                return false;
+            }
+
+        });
+    }
+
+    public void runJob2() {
+        executor.scheduleWithFixedDelay(new MyJob(), 1, 2, TimeUnit.MINUTES);
+    }
+
+    protected MyJob createJob() {
+        return new MyJob();
+    }
+}

batch/scheduling/src/main/java/org/javaee7/batch/samples/scheduling/MyTimerScheduleBean.java

@@ -0,0 +1,11 @@
+package org.javaee7.batch.samples.scheduling;
+
+import javax.ejb.Singleton;
+import javax.ejb.Startup;
+
+/**
+ * @author arungupta
+ */
+@Startup
+@Singleton
+public class MyTimerScheduleBean extends AbstractTimerBatch {}