Allow options to be passed via Symfony config, not just dsn

sroze · Nov 30, 2018 · 77a5965 · 77a5965
1 parent 0534e58
commit 77a5965
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/QueueInteropTransportFactory.php b/QueueInteropTransportFactory.php
@@ -49,7 +49,9 @@ public function createSender(string $dsn, array $options): TransportInterface
 
     public function createTransport(string $dsn, array $options): TransportInterface
     {
-        [$contextManager, $options] = $this->parseDsn($dsn);
+        [$contextManager, $dsnOptions] = $this->parseDsn($dsn);
+
+        $options = array_merge($dsnOptions, $options);
 
         return new QueueInteropTransport(
             $this->serializer,