Update AbstractConsumer.php

Fix nack
thecodingmachine · Jan 24, 2018 · ed6224e · ed6224e
1 parent 6fc6302
commit ed6224e
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/AbstractConsumer.php b/src/AbstractConsumer.php
@@ -26,18 +26,18 @@ public function callback($msg)
             $this->logger->error("Exception caught while consuming message.", [
                 'exception' => $e
             ]);
-            $msg->delivery_info['channel']->basic_nack($msg->delivery_info['delivery_tag'], true, true);
             if ($e instanceof FatalExceptionInterface) {
                 throw $e;
             }
+            $msg->delivery_info['channel']->basic_nack($msg->delivery_info['delivery_tag'], true, true);
         } catch (\Exception $e) {
             $this->logger->error("Exception caught while consuming message.", [
                 'exception' => $e
             ]);
-            $msg->delivery_info['channel']->basic_nack($msg->delivery_info['delivery_tag'], true, false);
             if ($e instanceof FatalExceptionInterface) {
                 throw $e;
             }
+            $msg->delivery_info['channel']->basic_nack($msg->delivery_info['delivery_tag'], true, false);
         }
     }