@Override
    public void onError(final Throwable t) {
        LOG.error("Messages write occur errors", t);
    }
@Test
    public void onError() {
        Throwable throwable = new Throwable();
        messageWriter.onError(throwable);
        
    }