@Test(groups = SMALL, expectedExceptions = IllegalStateException.class)
public void testCallingGetNewEventsWithoutCallingConnectThrowsException() {

    MysqlEventSource eventSource = new MysqlEventSource(provider, TEST_TABLE_NAME);
    eventSource.getNewEvents();
}