@Deployment(testable=false)
public static WebArchive createDeployment() {
    return ShrinkWrap.create(WebArchive.class)
            .addClasses(MyEndpointText.class,
                    MyEndpointTextClient.class,
                    MyEndpointByteArray.class,
                    MyEndpointByteArrayClient.class,
                    MyEndpointByteBuffer.class,
                    MyEndpointByteBufferClient.class,
                    MyEndpointInputStream.class,
                    MyEndpointInputStreamClient.class);
}

@Test
public void testTextEndpoint() throws URISyntaxException, DeploymentException, IOException, InterruptedException {
    MyEndpointTextClient.latch = new CountDownLatch(1);
    Session session = connectToServer(MyEndpointTextClient.class, "text");
    assertNotNull(session);
    assertTrue(MyEndpointTextClient.latch.await(2, TimeUnit.SECONDS));
    assertEquals(TEXT, MyEndpointTextClient.response);
}

@Test
public void testEndpointByteBuffer() throws URISyntaxException, DeploymentException, IOException, InterruptedException {
    MyEndpointByteBufferClient.latch = new CountDownLatch(1);
    Session session = connectToServer(MyEndpointByteBufferClient.class, "bytebuffer");
    assertNotNull(session);
    assertTrue(MyEndpointByteBufferClient.latch.await(2, TimeUnit.SECONDS));
    assertArrayEquals(TEXT.getBytes(), MyEndpointByteBufferClient.response);
}

@Test
public void testEndpointByteArray() throws DeploymentException, IOException, URISyntaxException, InterruptedException {
    MyEndpointByteArrayClient.latch = new CountDownLatch(1);
    Session session = connectToServer(MyEndpointByteArrayClient.class, "bytearray");
    assertNotNull(session);
    assertTrue(MyEndpointByteArrayClient.latch.await(2, TimeUnit.SECONDS));
    assertNotNull(MyEndpointByteArrayClient.response);
    assertArrayEquals(TEXT.getBytes(), MyEndpointByteArrayClient.response);
}

@Test
public void testEndpointInputStream() throws DeploymentException, IOException, URISyntaxException, InterruptedException {
    MyEndpointInputStreamClient.latch = new CountDownLatch(1);
    Session session = connectToServer(MyEndpointInputStreamClient.class, "inputstream");
    assertNotNull(session);
    assertTrue(MyEndpointInputStreamClient.latch.await(2, TimeUnit.SECONDS));
    assertNotNull(MyEndpointInputStreamClient.response);
    assertArrayEquals(TEXT.getBytes(), MyEndpointInputStreamClient.response);
}