|
@@ -122,7 +122,7 @@ |
|
|
block discarded – undo |
|
122
|
122
|
* @param string $routingKey |
|
123
|
123
|
* @return Consumer |
|
124
|
124
|
*/ |
|
125
|
|
- public function createConsumer($queueName, $queueUrl, $connectionId, $callback=null, $routingKey=null) |
|
|
125
|
+ public function createConsumer($queueName, $queueUrl, $connectionId, $callback = null, $routingKey = null) |
|
126
|
126
|
{ |
|
127
|
127
|
$class = $this->container->getParameter('kaliop_queueing.sqs.consumer.class'); |
|
128
|
128
|
$consumer = new $class($this->getConnectionConfig($connectionId)); |
Please login to merge, or discard this patch.