@@ -240,6 +240,9 @@ |
||
| 240 | 240 | } |
| 241 | 241 | } |
| 242 | 242 | |
| 243 | + /** |
|
| 244 | + * @param boolean $doHandle |
|
| 245 | + */ |
|
| 243 | 246 | public function setHandleSignals($doHandle) |
| 244 | 247 | { |
| 245 | 248 | $this->dispatchSignals = $doHandle; |
@@ -2,7 +2,6 @@ |
||
| 2 | 2 | |
| 3 | 3 | namespace Kaliop\Queueing\Plugins\StompBundle\Adapter\Stomp; |
| 4 | 4 | |
| 5 | -use Kaliop\QueueingBundle\Service\MessageProducer as BaseMessageProducer; |
|
| 6 | 5 | use Symfony\Component\DependencyInjection\ContainerAwareInterface; |
| 7 | 6 | use Symfony\Component\DependencyInjection\ContainerInterface; |
| 8 | 7 | use InvalidArgumentException; |
@@ -77,6 +77,9 @@ |
||
| 77 | 77 | $this->connections[$connectionId] = $params; |
| 78 | 78 | } |
| 79 | 79 | |
| 80 | + /** |
|
| 81 | + * @param string $connectionId |
|
| 82 | + */ |
|
| 80 | 83 | protected function getConnectionConfig($connectionId) |
| 81 | 84 | { |
| 82 | 85 | if (!isset($this->connections[$connectionId])) { |