|
@@ -78,6 +78,10 @@ class ProducerService
|
|
|
$entityRepository = $entityManager->getRepository($entityClass);
|
|
|
$entity = $entityRepository->find($entityId);
|
|
|
if (in_array($entityClass, WorkFlowEntityClasses::getConstants())) {
|
|
|
+ $routing_key = "";
|
|
|
+ if(getenv("AMQP_KEY") !== false){
|
|
|
+ $routing_key = getenv("AMQP_KEY");
|
|
|
+ }
|
|
|
$this->publishMessage($action, $entity);
|
|
|
}
|
|
|
}
|