Merge branch 'alexbumbacea-stop-restart-consumer'

RabbitMq/Consumer.php

@@ -90,6 +90,15 @@ public function processMessage(AMQPMessage $msg)
                     'return_code' => $processFlag
                 )
             ));
+        } catch (Exception\StopConsumerException $e) {
+            $this->logger->info('Consumer requested restart', array(
+                'amqp' => array(
+                    'queue' => $this->queueOptions['name'],
+                    'message' => $msg,
+                    'stacktrace' => $e->getTraceAsString()
+                )
+            ));
+            $this->stopConsuming();
         } catch (\Exception $e) {
             $this->logger->error($e->getMessage(), array(
                 'amqp' => array(

RabbitMq/Exception/StopConsumerException.php

@@ -0,0 +1,15 @@
+<?php
+
+namespace OldSound\RabbitMqBundle\RabbitMq\Exception;
+
+/**
+ * If this exception is thrown in consumer service the message
+ * will not be ack and consumer will stop
+ * if using demonized, ex: supervisor, the consumer will actually restart
+ * Class RestartConsumerException
+ * @package OldSound\RabbitMqBundle\RabbitMq\Exception
+ */
+class StopConsumerException extends \RuntimeException
+{
+
+}