@Test(groups = INTEGRATION)
public void testConnectCreatesCorrectEntryInListenerTable() throws SQLException {

    MysqlEventSource eventSource = new MysqlEventSource(provider, TEST_TABLE_NAME);
    eventSource.connect();
    assertEquals(listAllListeners().size(), 1);
}