@Test(groups = SMALL)
public void testConnectCreatesANewConnectionTheExistingWasClosed() throws SQLException {

    when(mockedConnection.isClosed()).thenReturn(true);
    eventSource.connect();
    eventSource.connect();
    verify(connectionProvider, times(3)).getConnection();
}