@Test(groups = SMALL)
public void testCorrectlyMapsAMysqlToAnEventWithAMapForOldAndNewEntities() {

    MysqlEventMapper mapper = new MysqlEventMapper();
    MysqlEvent mysqlEvent = new MysqlEvent(1, "tableName", "INSERT", "{}", "{'key':'value'}", new Date());
    Event<Map<String, Object>> genericEvent = mapper.mapToGenericEvent(mysqlEvent);
    assertEquals(genericEvent.getEventType(), mysqlEvent.getEventType());
    assertEquals(genericEvent.getEntityName(), mysqlEvent.getEntityName());
    assertEquals(genericEvent.getNewEntity().size(), 1);
    assertEquals(genericEvent.getOldEntity().size(), 0);
}