@@ -18,6 +18,9 @@ |
||
18 | 18 | return $consumer; |
19 | 19 | } |
20 | 20 | |
21 | + /** |
|
22 | + * @param string $queueName |
|
23 | + */ |
|
21 | 24 | protected function getQueueCallback($queueName) |
22 | 25 | { |
23 | 26 | $callbacks = $this->container->getParameter('kaliop_queueing_kinesis.default.consumers'); |