compatibility with old config

martianoff · martianoff · commit 63b959b32639 · 2018-03-27T16:35:21.000+07:00
diff --git a/src/Connectors/AmqpConnector.php b/src/Connectors/AmqpConnector.php
@@ -48,7 +48,7 @@ public function connect(array $config)
         }
 
         return new AMQPQueue(
-            $connection, $config['queue'], $config['queue_flags'], $config['declare_queues'],
+            $connection, $config['queue'], $config['queue_flags'], isset($config['declare_queues']) ? $config['declare_queues'] : true,
             $config['message_properties'], $config['channel_id'],
             $config['exchange_name'], $config['exchange_type'], $config['exchange_flags']
         );

Original file line number	Diff line number	Diff line change
`@@ -48,7 +48,7 @@ public function connect(array $config)`
`48`	`48`	`}`
`49`	`49`
`50`	`50`	`return new AMQPQueue(`
`51`		`- $connection, $config['queue'], $config['queue_flags'], $config['declare_queues'],`
	`51`	`+ $connection, $config['queue'], $config['queue_flags'], isset($config['declare_queues']) ? $config['declare_queues'] : true,`
`52`	`52`	`$config['message_properties'], $config['channel_id'],`
`53`	`53`	`$config['exchange_name'], $config['exchange_type'], $config['exchange_flags']`
`54`	`54`	`);`