Adding programmatic timer sample

airborn · airborn · commit fa235833926c · 2015-03-27T23:13:29.000+01:00
diff --git a/ejb/timer/src/main/java/org/javaee7/ejb/timer/ProgrammaticTimerBean.java b/ejb/timer/src/main/java/org/javaee7/ejb/timer/ProgrammaticTimerBean.java
@@ -0,0 +1,39 @@
+package org.javaee7.ejb.timer;
+
+import javax.annotation.PostConstruct;
+import javax.annotation.Resource;
+import javax.ejb.*;
+import javax.enterprise.event.Event;
+import javax.inject.Inject;
+
+/**
+ * author: Jacek Jackowiak
+ */
+@Startup
+@Singleton
+public class ProgrammaticTimerBean {
+
+    @Inject
+    Event<Ping> pingEvent;
+
+    @Resource
+    TimerService timerService;
+
+    @PostConstruct
+    public void initialize(){
+        ScheduleExpression scheduleExpression = new ScheduleExpression();
+        scheduleExpression.hour("*");
+        scheduleExpression.minute("*");
+        scheduleExpression.second("*/5");
+
+        TimerConfig timerConfig = new TimerConfig();
+        timerConfig.setInfo("Every 5 second timer");
+
+        timerService.createCalendarTimer(scheduleExpression, timerConfig);
+    }
+
+    @Timeout
+    public void programmaticTimout(Timer timer) {
+        pingEvent.fire(new Ping(timer.getInfo().toString()));
+    }
+}
diff --git a/ejb/timer/src/test/java/org/javaee7/ejb/timer/ProgrammaticTimerBeanTest.java b/ejb/timer/src/test/java/org/javaee7/ejb/timer/ProgrammaticTimerBeanTest.java
@@ -0,0 +1,73 @@
+package org.javaee7.ejb.timer;
+
+import org.hamcrest.BaseMatcher;
+import org.hamcrest.Description;
+import org.hamcrest.Matcher;
+import org.jboss.arquillian.container.test.api.Deployment;
+import org.jboss.arquillian.junit.Arquillian;
+import org.jboss.shrinkwrap.api.ShrinkWrap;
+import org.jboss.shrinkwrap.api.spec.WebArchive;
+import org.jboss.shrinkwrap.resolver.api.maven.Maven;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+
+import javax.inject.Inject;
+import java.io.File;
+
+import static com.jayway.awaitility.Awaitility.await;
+import static com.jayway.awaitility.Awaitility.to;
+import static org.hamcrest.MatcherAssert.assertThat;
+import static org.hamcrest.Matchers.equalTo;
+import static org.hamcrest.Matchers.is;
+
+/**
+ * author: Jacek Jackowiak
+ */
+@RunWith(Arquillian.class)
+public class ProgrammaticTimerBeanTest {
+
+    final static long TIMEOUT = 5000l;
+    final static long TOLERANCE = 1000l;
+
+    @Inject
+    PingsListener pings;
+
+    @Deployment
+    public static WebArchive deploy() {
+        File[] jars = Maven.resolver().loadPomFromFile("pom.xml")
+                .resolve("com.jayway.awaitility:awaitility")
+                .withTransitivity().asFile();
+
+        return ShrinkWrap.create(WebArchive.class)
+                .addAsLibraries(jars)
+                .addClasses(Ping.class, PingsListener.class, ProgrammaticTimerBean.class);
+    }
+
+    @Test
+    public void should_receive_two_pings() {
+        await().untilCall(to(pings.getPings()).size(), equalTo(2));
+
+        Ping firstPing = pings.getPings().get(0);
+        Ping secondPing = pings.getPings().get(1);
+
+        long delay = secondPing.getTime() - firstPing.getTime();
+        System.out.println("Actual timeout = " + delay);
+        assertThat(delay, is(withinWindow(TIMEOUT, TOLERANCE)));
+    }
+
+    private Matcher<Long> withinWindow(final long timeout, final long tolerance) {
+        return new BaseMatcher<Long>() {
+            @Override
+            public boolean matches(Object item) {
+                final Long actual = (Long) item;
+                return Math.abs(actual - timeout) < tolerance;
+            }
+
+            @Override
+            public void describeTo(Description description) {
+                //To change body of implemented methods use File | Settings | File Templates.
+            }
+        };
+    }
+
+}
