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