From a8e161e1e83df823a2078bad042d4655313b2def Mon Sep 17 00:00:00 2001 From: Joeri Verdeyen Date: Sat, 21 Oct 2017 23:16:05 +0200 Subject: [PATCH] Only add Ampq transport factories when packages are found --- pkg/enqueue-bundle/EnqueueBundle.php | 13 +++++++++++-- 1 file changed, 11 insertions(+), 2 deletions(-) diff --git a/pkg/enqueue-bundle/EnqueueBundle.php b/pkg/enqueue-bundle/EnqueueBundle.php index e7698c5b5..384dc374d 100644 --- a/pkg/enqueue-bundle/EnqueueBundle.php +++ b/pkg/enqueue-bundle/EnqueueBundle.php @@ -2,6 +2,9 @@ namespace Enqueue\Bundle; +use Enqueue\AmqpBunny\AmqpConnectionFactory as AmqpBunnyConnectionFactory; +use Enqueue\AmqpExt\AmqpConnectionFactory as AmqpExtConnectionFactory; +use Enqueue\AmqpLib\AmqpConnectionFactory as AmqpLibConnectionFactory; use Enqueue\AsyncEventDispatcher\DependencyInjection\AsyncEventsPass; use Enqueue\AsyncEventDispatcher\DependencyInjection\AsyncTransformersPass; use Enqueue\Bundle\DependencyInjection\Compiler\BuildClientExtensionsPass; @@ -54,8 +57,14 @@ public function build(ContainerBuilder $container) $extension->addTransportFactory(new RabbitMqStompTransportFactory()); } - $extension->addTransportFactory(new AmqpTransportFactory('amqp')); - $extension->addTransportFactory(new RabbitMqAmqpTransportFactory('rabbitmq_amqp')); + if ( + class_exists(AmqpBunnyConnectionFactory::class) || + class_exists(AmqpExtConnectionFactory::class) || + class_exists(AmqpLibConnectionFactory::class) + ) { + $extension->addTransportFactory(new AmqpTransportFactory('amqp')); + $extension->addTransportFactory(new RabbitMqAmqpTransportFactory('rabbitmq_amqp')); + } if (class_exists(FsConnectionFactory::class)) { $extension->addTransportFactory(new FsTransportFactory());