Fix

Author: makasim

pkg/enqueue/Symfony/DefaultTransportFactory.php

@@ -5,6 +5,7 @@
 use Enqueue\AmqpExt\AmqpConnectionFactory;
 use Enqueue\AmqpExt\Symfony\AmqpTransportFactory;
 use Enqueue\Dbal\DbalConnectionFactory;
+use Enqueue\Dbal\Symfony\DbalTransportFactory;
 use Enqueue\Fs\FsConnectionFactory;
 use Enqueue\Fs\Symfony\FsTransportFactory;
 use Enqueue\Null\NullConnectionFactory;
@@ -144,7 +145,7 @@ private function findFactory($dsn)
         }
 
         if ($connectionFactory instanceof DbalConnectionFactory) {
-            return new FsTransportFactory('default_dbal');
+            return new DbalTransportFactory('default_dbal');
         }
 
         if ($connectionFactory instanceof NullConnectionFactory) {