Simple implementation of MyTrigger

aheusingfeld · aheusingfeld · commit 820d0ea97bd3 · 2014-03-25T11:40:09.000+01:00
diff --git a/concurrency/managedscheduledexecutor/src/main/java/org/javaee7/concurrency/managedscheduledexecutor/MyTrigger.java b/concurrency/managedscheduledexecutor/src/main/java/org/javaee7/concurrency/managedscheduledexecutor/MyTrigger.java
@@ -39,23 +39,32 @@
  */
 package org.javaee7.concurrency.managedscheduledexecutor;
 
-import java.util.Date;
 import javax.enterprise.concurrent.LastExecution;
 import javax.enterprise.concurrent.Trigger;
+import java.util.Date;
 
 /**
  * @author Arun Gupta
  */
 public class MyTrigger implements Trigger {
 
+    private final Date firetime;
+
+    public MyTrigger(Date firetime) {
+        this.firetime = firetime;
+    }
+
     @Override
-    public Date getNextRunTime(LastExecution le, Date date) {
-        throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
+    public Date getNextRunTime(LastExecution le, Date taskScheduledTime) {
+        if (firetime.before(taskScheduledTime)) {
+            return null;
+        }
+        return firetime;
     }
 
     @Override
-    public boolean skipRun(LastExecution le, Date date) {
-        throw new UnsupportedOperationException("Not supported yet."); //To change body of generated methods, choose Tools | Templates.
+    public boolean skipRun(LastExecution le, Date scheduledRunTime) {
+        return firetime.before(scheduledRunTime);
     }
     
 }
diff --git a/concurrency/managedscheduledexecutor/src/main/java/org/javaee7/concurrency/managedscheduledexecutor/TestTriggerServlet.java b/concurrency/managedscheduledexecutor/src/main/java/org/javaee7/concurrency/managedscheduledexecutor/TestTriggerServlet.java
@@ -39,15 +39,16 @@
  */
 package org.javaee7.concurrency.managedscheduledexecutor;
 
-import java.io.IOException;
-import java.io.PrintWriter;
 import javax.annotation.Resource;
 import javax.enterprise.concurrent.ManagedScheduledExecutorService;
 import javax.servlet.ServletException;
 import javax.servlet.annotation.WebServlet;
 import javax.servlet.http.HttpServlet;
 import javax.servlet.http.HttpServletRequest;
 import javax.servlet.http.HttpServletResponse;
+import java.io.IOException;
+import java.io.PrintWriter;
+import java.util.Date;
 
 /**
  * @author Arun Gupta
@@ -81,7 +82,7 @@ protected void processRequest(HttpServletRequest request, HttpServletResponse re
             out.println("<body>");
             out.println("<h1>Schedule tasks with a trigger</h1>");
             for (int i=0; i<5; i++) {
-                executor.schedule(new MyRunnableTask(i), new MyTrigger());
+                executor.schedule(new MyRunnableTask(i), new MyTrigger(new Date(System.currentTimeMillis() + 30000)));
             }
             out.println("<br><br>Check server.log for output");
             
