@Deployment(testable = false)
public static WebArchive deploy() throws URISyntaxException {
    return ShrinkWrap.create(WebArchive.class)
            .addClass(MyAsyncEndpointText.class)
            .addClass(MyAsyncEndpointByteBuffer.class);
}

@Test
public void shouldReceiveAsyncTextMessage() throws URISyntaxException, IOException, DeploymentException {
    MyAsyncEndpointTextClient endpoint = new MyAsyncEndpointTextClient();
    Session session = connectToEndpoint(endpoint, "text");

    session.getAsyncRemote().sendText(TEST_MESSAGE);

    await().untilCall(to(endpoint).getReceivedMessage(), is(equalTo(TEST_MESSAGE)));
}

@Test
public void shouldReceiveAsyncByteBufferMessage() throws URISyntaxException, IOException, DeploymentException {
    final ByteBuffer buffer = ByteBuffer.wrap(TEST_MESSAGE.getBytes());
    MyAsyncEndpointByteBufferClient endpoint = new MyAsyncEndpointByteBufferClient();
    Session session = connectToEndpoint(endpoint, "bytebuffer");

    session.getAsyncRemote().sendBinary(buffer);

    await().untilCall(to(endpoint).getReceivedMessage(), is(notNullValue()));
    String receivedString = bufferToString(endpoint.getReceivedMessage());
    assertThat(receivedString, is(equalTo(TEST_MESSAGE)));
}