#392 - ack before stopping consumer (#400)

* #392 - ack before stopping consumer

* Add new line

Author: alexbumbacea

RabbitMq/Consumer.php

@@ -114,6 +114,7 @@ protected function processMessageQueueCallback(AMQPMessage $msg, $queueName, $ca
                     'stacktrace' => $e->getTraceAsString()
                 )
             ));
+            $this->handleProcessMessage($msg, $e->getHandleCode());
             $this->stopConsuming();
         } catch (\Exception $e) {
             $this->logger->error($e->getMessage(), array(

RabbitMq/Exception/AckStopConsumerException.php

@@ -0,0 +1,15 @@
+<?php
+
+namespace OldSound\RabbitMqBundle\RabbitMq\Exception;
+
+
+use OldSound\RabbitMqBundle\RabbitMq\ConsumerInterface;
+
+class AckStopConsumerException extends StopConsumerException
+{
+    public function getHandleCode()
+    {
+        return ConsumerInterface::MSG_ACK;
+    }
+
+}

RabbitMq/Exception/StopConsumerException.php

@@ -1,6 +1,7 @@
 <?php
 
 namespace OldSound\RabbitMqBundle\RabbitMq\Exception;
+use OldSound\RabbitMqBundle\RabbitMq\ConsumerInterface;
 
 /**
  * If this exception is thrown in consumer service the message
@@ -11,6 +12,10 @@
  */
 class StopConsumerException extends \RuntimeException
 {
+    public function getHandleCode()
+    {
+        return ConsumerInterface::MSG_SINGLE_NACK_REQUEUE;
+    }
 
 }