allow generic parameters to be passed to connection constructors

Author: goetas

Provider/ConnectionParametersProviderInterface.php

@@ -25,8 +25,12 @@ interface ConnectionParametersProviderInterface
      *   'keepalive' => false,
      *   'heartbeat' => 0,
      *   'use_socket' => true,
+     *   'constructor_args' => array(...)
      * )
      *
+     * If constructor_args is present, all the other parameters are ignored; constructor_args are passes as constructor
+     * arguments.
+     *
      * @return array
      */
     public function getConnectionParameters();

RabbitMq/AMQPConnectionFactory.php

@@ -60,6 +60,11 @@ public function __construct(
      */
     public function createConnection()
     {
+        if (isset($this->parameters['constructor_args']) && is_array($this->parameters['constructor_args'])) {
+            $ref = new \ReflectionClass($this->class);
+            return $ref->newInstanceArgs($this->parameters['constructor_args']);
+        }
+
         if ($this->class == 'PhpAmqpLib\Connection\AMQPSocketConnection' || is_subclass_of($this->class , 'PhpAmqpLib\Connection\AMQPSocketConnection')) {
             return new $this->class(
                 $this->parameters['host'],

Tests/RabbitMq/AMQPConnectionFactoryTest.php

@@ -269,6 +269,28 @@ public function testSSLConnectionParameters()
         ), $instance->constructParams);
     }
 
+    public function testConnectionsParametersProviderWithConstructorArgs()
+    {
+        $connectionParametersProvider = $this->prepareConnectionParametersProvider();
+        $connectionParametersProvider->expects($this->once())
+            ->method('getConnectionParameters')
+            ->will($this->returnValue(
+                array(
+                    'constructor_args' => array(1,2,3,4)
+                )
+            ));
+        $factory = new AMQPConnectionFactory(
+            'OldSound\RabbitMqBundle\Tests\RabbitMq\Fixtures\AMQPConnection',
+            array(),
+            $connectionParametersProvider
+        );
+
+        /** @var AMQPConnection $instance */
+        $instance = $factory->createConnection();
+        $this->assertInstanceOf('OldSound\RabbitMqBundle\Tests\RabbitMq\Fixtures\AMQPConnection', $instance);
+        $this->assertEquals(array(1,2,3,4), $instance->constructParams);
+    }
+
     public function testConnectionsParametersProvider()
     {
         $connectionParametersProvider = $this->prepareConnectionParametersProvider();