Skip to content

Commit a8e161e

Browse files
committed
Only add Ampq transport factories when packages are found
1 parent a55b98a commit a8e161e

File tree

1 file changed

+11
-2
lines changed

1 file changed

+11
-2
lines changed

Diff for: pkg/enqueue-bundle/EnqueueBundle.php

+11-2
Original file line numberDiff line numberDiff line change
@@ -2,6 +2,9 @@
22

33
namespace Enqueue\Bundle;
44

5+
use Enqueue\AmqpBunny\AmqpConnectionFactory as AmqpBunnyConnectionFactory;
6+
use Enqueue\AmqpExt\AmqpConnectionFactory as AmqpExtConnectionFactory;
7+
use Enqueue\AmqpLib\AmqpConnectionFactory as AmqpLibConnectionFactory;
58
use Enqueue\AsyncEventDispatcher\DependencyInjection\AsyncEventsPass;
69
use Enqueue\AsyncEventDispatcher\DependencyInjection\AsyncTransformersPass;
710
use Enqueue\Bundle\DependencyInjection\Compiler\BuildClientExtensionsPass;
@@ -54,8 +57,14 @@ public function build(ContainerBuilder $container)
5457
$extension->addTransportFactory(new RabbitMqStompTransportFactory());
5558
}
5659

57-
$extension->addTransportFactory(new AmqpTransportFactory('amqp'));
58-
$extension->addTransportFactory(new RabbitMqAmqpTransportFactory('rabbitmq_amqp'));
60+
if (
61+
class_exists(AmqpBunnyConnectionFactory::class) ||
62+
class_exists(AmqpExtConnectionFactory::class) ||
63+
class_exists(AmqpLibConnectionFactory::class)
64+
) {
65+
$extension->addTransportFactory(new AmqpTransportFactory('amqp'));
66+
$extension->addTransportFactory(new RabbitMqAmqpTransportFactory('rabbitmq_amqp'));
67+
}
5968

6069
if (class_exists(FsConnectionFactory::class)) {
6170
$extension->addTransportFactory(new FsTransportFactory());

0 commit comments

Comments
 (0)