Introduce a RABBITMQ_URL

This commit is contained in:
Yassine Guedidi 2025-02-22 14:57:53 +01:00
parent 598515868c
commit f9847a0099
2 changed files with 19 additions and 6 deletions

View file

@ -78,6 +78,7 @@ class AppKernel extends Kernel
$loader->load(function (ContainerBuilder $container) { $loader->load(function (ContainerBuilder $container) {
$this->processDatabaseParameters($container); $this->processDatabaseParameters($container);
$this->defineRedisUrlEnvVar($container); $this->defineRedisUrlEnvVar($container);
$this->defineRabbitMqUrlEnvVar($container);
}); });
} }
@ -138,4 +139,20 @@ class AppKernel extends Kernel
$container->setParameter('env(REDIS_URL)', $url); $container->setParameter('env(REDIS_URL)', $url);
} }
private function defineRabbitMqUrlEnvVar(ContainerBuilder $container)
{
$host = $container->getParameter('rabbitmq_host');
$port = $container->getParameter('rabbitmq_port');
$user = $container->getParameter('rabbitmq_user');
$password = $container->getParameter('rabbitmq_password');
$url = 'amqp://' . $user . ':' . $password . '@' . $host;
if ($port) {
$url .= ':' . $port;
}
$container->setParameter('env(RABBITMQ_URL)', $url);
}
} }

View file

@ -239,12 +239,8 @@ rulerz:
old_sound_rabbit_mq: old_sound_rabbit_mq:
connections: connections:
default: default:
host: "%rabbitmq_host%" url: "%env(RABBITMQ_URL)%"
port: "%rabbitmq_port%" lazy: true
user: "%rabbitmq_user%"
password: "%rabbitmq_password%"
vhost: /
lazy: true
producers: producers:
import_pocket: import_pocket:
connection: default connection: default