|
@@ -118,7 +118,7 @@ |
|
|
block discarded – undo |
|
118
|
118
|
* @param string $scope |
|
119
|
119
|
* @return Consumer |
|
120
|
120
|
*/ |
|
121
|
|
- public function createConsumer($queueName, $queueDestination, $connectionId, $subscriptionName, $callback=null, $routingKey=null, $scope=ContainerInterface::SCOPE_CONTAINER) |
|
|
121
|
+ public function createConsumer($queueName, $queueDestination, $connectionId, $subscriptionName, $callback = null, $routingKey = null, $scope = ContainerInterface::SCOPE_CONTAINER) |
|
122
|
122
|
{ |
|
123
|
123
|
$class = $this->container->getParameter('kaliop_queueing.stomp.consumer.class'); |
|
124
|
124
|
$consumer = new $class($this->getConnectionConfig($connectionId)); |
Please login to merge, or discard this patch.