@Test
public void testConnectEvent() {

    manager.publishConnect("sessionId");
    verify(listener, only()).onConnect(stringCaptor.capture());
    String id = stringCaptor.getValue();
    assertThat(id, is(equalTo("sessionId")));
}