@Test(groups = SMALL, expectedExceptions = DataAccessException.class)
public void testConnectThrowsDataAccessExceptionWhenCanNotGetConnectionToTheDb() {

    when(connectionProvider.getConnection()).thenThrow(new DataAccessException(""));
    eventSource.connect();
}