@Deployment
public static WebArchive deploy() {
    return ShrinkWrap.create(WebArchive.class)
            .addClasses(MessageSenderSync.class,
                    MessageReceiverSync.class,
                    ClassicMessageSender.class,
                    ClassicMessageReceiver.class,
                    MessageSenderAppManaged.class,
                    MessageReceiverAppManaged.class,
                    Resources.class);
}

@Test
public void testClassicApi() {
    String message = "The test message over JMS 1.1 API";
    classicSender.sendMessage(message);

    assertEquals(message, classicReceiver.receiveMessage());
}

@Test
public void testContainerManagedJmsContext() {
    String message = "Test message over container-managed JMSContext";
    simpleSender.sendMessage(message);

    assertEquals(message, simpleReceiver.receiveMessage());
}

@Test
public void testAppManagedJmsContext() {
    String message = "The test message over app-managed JMSContext";
    appManagedSender.sendMessage(message);

    assertEquals(message, appManagedReceiver.receiveMessage());
}

@Test
public void testMultipleSendAndReceive() {
    simpleSender.sendMessage("1");
    simpleSender.sendMessage("2");
    assertEquals("1", simpleReceiver.receiveMessage());
    assertEquals("2", simpleReceiver.receiveMessage());
    simpleSender.sendMessage("3");
    simpleSender.sendMessage("4");
    simpleSender.sendMessage("5");
    assertEquals("3", simpleReceiver.receiveMessage());
    assertEquals("4", simpleReceiver.receiveMessage());
    assertEquals("5", simpleReceiver.receiveMessage());
}

@Deployment
public static WebArchive deploy() {
    return ShrinkWrap.create(WebArchive.class)
            .addClass(MessageSenderAsync.class)
            .addClass(Resources.class)
            .addClass(MessageReceiverAsync.class)
            .addClass(ReceptionSynchronizer.class)
            .addAsWebInfResource(new File("src/test/resources/WEB-INF/ejb-jar.xml"));
}

@Test
public void testAsync() throws Exception {
    asyncSender.sendMessage("Fire!");
    ReceptionSynchronizer.waitFor(MessageReceiverAsync.class, "onMessage");
    // unless we timed out, the test passes
}

@Test
public void testWaiting() throws NoSuchMethodException, InterruptedException {
    final ReceptionSynchronizer cut = new ReceptionSynchronizer();
    ScheduledExecutorService pool = Executors.newScheduledThreadPool(1);
    final Method method = ReceptionSynchronizerTest.class.getDeclaredMethod("testWaiting");
    long startTime = System.currentTimeMillis();
    pool.schedule(new Runnable() {

        @Override
        public void run() {
            cut.registerInvocation(method);
        }
    }, 1, TimeUnit.SECONDS);
    ReceptionSynchronizer.waitFor(ReceptionSynchronizerTest.class, "testWaiting");
    long waitTime = System.currentTimeMillis()-startTime;
    assertTrue("Waited more than 950ms", waitTime > 950);
    assertTrue("Waited no longer than 1050ms", waitTime < 1050);
}