@Test
public void testConnectErrorEvent() {

    Throwable throwable = new IOException("IOException");
    manager.publishConnectError(throwable);
    verify(listener, only()).onConnectError(throwableCaptor.capture());
    assertThat(throwableCaptor.getValue(), is(equalTo(throwable)));
}