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

    List<MysqlEvent> newEvents = repo.getNewEventsForListener(listener, connection);
    assertTrue(newEvents.isEmpty());
    insertEvent(new MysqlEvent(1, TEST_TABLE_NAME, INSERT_TYPE, "{}", "{}", new Date()), connection);
    newEvents = repo.getNewEventsForListener(listener, connection);
    assertEquals(newEvents.size(), 1);
}