<?php

class EntityListener {
    public function onFlush(OnFlushEventArgs $event)
    {
        $this->emailActivityUpdates->processCreatedEntities($uow->getScheduledEntityInsertions());
    }

    protected function addAssociationWithEmailActivity(PostFlushEventArgs $event) {
        $jobs = $this->emailActivityUpdates->createJobs();
        if (!$jobs) {
            return;
        }

        $em = $event->getEntityManager();
        array_map([$em, 'persist'], $jobs);
        $em->flush();
    }
}

class EmailActivityUpdates {
    public function processCreatedEntities(array $entities) {}
    public function createJobs() {}
}