Skip to content

Commit d3fa1ca

Browse files
committed
Add the rdkafka transport factory to the EnqueueBundle class
1 parent 7fc3a10 commit d3fa1ca

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

pkg/enqueue-bundle/EnqueueBundle.php

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,8 @@
2121
use Enqueue\Fs\Symfony\FsTransportFactory;
2222
use Enqueue\Gps\GpsConnectionFactory;
2323
use Enqueue\Gps\Symfony\GpsTransportFactory;
24+
use Enqueue\RdKafka\RdKafkaConnectionFactory;
25+
use Enqueue\RdKafka\Symfony\RdKafkaTransportFactory;
2426
use Enqueue\Redis\RedisConnectionFactory;
2527
use Enqueue\Redis\Symfony\RedisTransportFactory;
2628
use Enqueue\Sqs\SqsConnectionFactory;
@@ -104,6 +106,12 @@ class_exists(AmqpLibConnectionFactory::class)
104106
$extension->setTransportFactory(new MissingTransportFactory('gps', ['enqueue/gps']));
105107
}
106108

109+
if (class_exists(RdKafkaConnectionFactory::class)) {
110+
$extension->setTransportFactory(new RdKafkaTransportFactory('rdkafka'));
111+
} else {
112+
$extension->setTransportFactory(new MissingTransportFactory('rdkafka', ['enqueue/rdkafka']));
113+
}
114+
107115
$container->addCompilerPass(new AsyncEventsPass(), PassConfig::TYPE_BEFORE_OPTIMIZATION, 100);
108116
$container->addCompilerPass(new AsyncTransformersPass(), PassConfig::TYPE_BEFORE_OPTIMIZATION, 100);
109117
}

0 commit comments

Comments
 (0)