флаш вызываете ?

учитываете что консьюмер это по сути демон работающий непрерывно ?

да, флашу в конце, все как обычное создание записи

и что пишет ? какие ошибки ?

A new entity was found through the relationship 'ActivityJournalBundle\Entity\UserActivity#user' that was not configured to cascade persist operations for entity: Igor. To solve this issue: Either explicitly call EntityManager#persist() on this unknown entity or configure cascade persist this association in the mapping for example @ManyToOne(..,cascade={"persist"}).","exception" => Symfony\Component\Messenger\Exception\HandlerFailedException { …}]

если без очереди, то все окей создает, а здесь такая херня

em->clear вызываете ?

нет, не знаком с этой функцией

можно подробнее?

и как его применить правильно?

ну судя по всему либо вы как-то не так создаете сущность (что вероятнее) либо же не учитываете логику работы консьюмера
поэтому на вашем месте я бы сначала очистил UoW перед процессингом сообщения из очереди - для надежности
а потом бы разбирался с тем как вы там сущность создаете в очереди

подозреваю что вы пропускаете в своем сознании какую-то закулисную работу фреймворка или самой доктрины, который происходит не в консьюмере, а в консьюмере ее нет

да, я тоже думаю за это
первый раз работаю с очередями, потому и не знаю все нюансов здесь

я так понял у вас две сущности User и UserActivity ?

они связаны через OneToMany ?

да, так и есть + еще клиент, по той же схеме

но там такая же ошибка валится, когда персищу

покажите код персиста из очереди

и из другой части где работает

Очередь:
   public function createRecord(object $model)
   {
       $record = new UserActivity();
       $record
           ->setUser($model->getUser())
           ->setActionType(1)
           ->setEntityId($model->getEntity()->getId())
           ->setEntityName(get_class($model->getEntity()));

       $this->em->persist($record);
       $this->em->flush();
   }

Обычная:
       /** @var UserActivityModel $item */
       foreach ($this->chain as $item)
       {
           $record = new UserActivity();
           $record
               ->setEntityName(get_class($item->getEntity()))
               ->setUser($user)
               ->setEntityId($item->getEntity()->getId())
               ->setActionType(1);

           $this->em->persist($record);
       }
       $this->em->flush();