@Deployment(testable=false)
public static WebArchive createDeployment() {
    return ShrinkWrap.create(WebArchive.class)
            .addClasses(MyEndpoint.class,
                    MyEndpointConfig.class,
                    MyEndpointTextClient.class,
                    MyEndpointBinaryClient.class);
}

@Test
public void testTextEndpoint() throws URISyntaxException, DeploymentException, IOException, InterruptedException {
    MyEndpointTextClient.latch = new CountDownLatch(1);
    final String TEXT = "Hello World!";
    Session session = connectToServer(MyEndpointTextClient.class);
    assertNotNull(session);
    session.addMessageHandler(new MessageHandler.Whole<String>() {
        @Override
        public void onMessage(String text) {
            assertEquals(TEXT, text);
        }
    });
    assertTrue(MyEndpointTextClient.latch.await(2, TimeUnit.SECONDS));
}

@Test
public void testBinaryEndpoint() throws URISyntaxException, DeploymentException, IOException, InterruptedException {
    MyEndpointBinaryClient.latch = new CountDownLatch(1);
    final String TEXT = "Hello World!";
    Session session = connectToServer(MyEndpointBinaryClient.class);
    assertNotNull(session);
    session.addMessageHandler(new MessageHandler.Whole<ByteBuffer>() {
        @Override
        public void onMessage(ByteBuffer binary) {
            assertEquals(TEXT, binary);
        }
    });
    assertTrue(MyEndpointBinaryClient.latch.await(2, TimeUnit.SECONDS));
}