@Test(groups = SMALL)
public void testConnectDoesntGetANewConnectionIfOneAlreadyExistsAndIsOpen() {

    eventSource.connect();
    eventSource.connect();
    verify(connectionProvider, times(2)).getConnection();
}