Merge pull request #4 from tejerka/master

Change from error to warning when try to add alias on unknown queue

Author: tejerka

CHANGELOG.md

@@ -1,5 +1,9 @@
 # Queue Client Bundle Changelog
 
+## v1.0.3
+
+- Change from error to warning when try to add alias on unknown queue
+
 ## v1.0.2
 
 - Add AWS backwards compatibility

QueueClientFactory.php

@@ -2,8 +2,10 @@
 
 namespace ReputationVIP\Bundle\QueueClientBundle;
 
+use Psr\Log\LoggerInterface;
 use ReputationVIP\Bundle\QueueClientBundle\Configuration\QueuesConfiguration;
 use ReputationVIP\QueueClient\Adapter\AdapterInterface;
+use ReputationVIP\QueueClient\Adapter\Exception\QueueAccessException;
 use ReputationVIP\QueueClient\QueueClient;
 use ReputationVIP\QueueClient\QueueClientInterface;
 use Symfony\Component\Config\Definition\Processor;
@@ -42,6 +44,8 @@ public static function resolveParameters(&$item, $key, $container)
      */
     public function get($container, $adapter, $queuesFile)
     {
+        /** @var LoggerInterface $logger */
+        $logger = $container->get('logger');
         $queueClient = new QueueClient($adapter);
         $processor = new Processor();
         $configuration = new QueuesConfiguration();
@@ -53,6 +57,8 @@ public function get($container, $adapter, $queuesFile)
             foreach ($queue[QueuesConfiguration::QUEUE_ALIASES_NODE] as $alias) {
                 try {
                     $queueClient->addAlias($queueName, $alias);
+                } catch (QueueAccessException $e) {
+                    $logger->warning($e->getMessage());
                 } catch (\ErrorException $e) {
                     if ($e->getSeverity() === E_ERROR) {
                         throw $e;