@Override
    public void onMessage(Message<E> message) {
        messageListener.onMessage(message);
    }
@Test
    public void onMessage() {
        MessageListener<String> listener = createMessageListenerMock();
        ReliableMessageListenerAdapter<String> adapter = new ReliableMessageListenerAdapter<>(listener);

        Message<String> message = new Message<>("foo", "foo", System.currentTimeMillis(), null);
        adapter.onMessage(message);

        verify(listener).onMessage(message);
    }