File tree 1 file changed +7
-0
lines changed
1 file changed +7
-0
lines changed Original file line number Diff line number Diff line change 21
21
use Enqueue \Fs \Symfony \FsTransportFactory ;
22
22
use Enqueue \Gps \GpsConnectionFactory ;
23
23
use Enqueue \Gps \Symfony \GpsTransportFactory ;
24
+ use Enqueue \Mongodb \Symfony \MongodbTransportFactory ;
24
25
use Enqueue \RdKafka \RdKafkaConnectionFactory ;
25
26
use Enqueue \RdKafka \Symfony \RdKafkaTransportFactory ;
26
27
use Enqueue \Redis \RedisConnectionFactory ;
@@ -112,6 +113,12 @@ class_exists(AmqpLibConnectionFactory::class)
112
113
$ extension ->setTransportFactory (new MissingTransportFactory ('rdkafka ' , ['enqueue/rdkafka ' ]));
113
114
}
114
115
116
+ if (class_exists (MongodbTransportFactory::class)) {
117
+ $ extension ->setTransportFactory (new MongodbTransportFactory ('mongodb ' ));
118
+ } else {
119
+ $ extension ->setTransportFactory (new MissingTransportFactory ('mongodb ' , ['enqueue/mongodb ' ]));
120
+ }
121
+
115
122
$ container ->addCompilerPass (new AsyncEventsPass (), PassConfig::TYPE_BEFORE_OPTIMIZATION , 100 );
116
123
$ container ->addCompilerPass (new AsyncTransformersPass (), PassConfig::TYPE_BEFORE_OPTIMIZATION , 100 );
117
124
}
You can’t perform that action at this time.
0 commit comments