init (#17)

Co-authored-by: evgeny.iva <[email protected]>

Author: evgeek

src/Rabbit/Consumer.php

@@ -8,7 +8,6 @@
 use PhpAmqpLib\Message\AMQPMessage;
 use Psr\Log\LoggerInterface;
 use Psr\Log\NullLogger;
-use Throwable;
 
 class Consumer
 {
@@ -62,21 +61,13 @@ private function handle(AMQPMessage $amqpMessage): void
         $message = $this->messageBuilder->buildReceivedMessage($amqpMessage);
         $messageId = $amqpMessage->delivery_info['delivery_tag'];
 
-        try {
-            $this->config->handler()
-                ->handle($message);
-            $this->channelContainer->getChannel()
-                ->basic_ack($messageId);
-            $this->logger->info("Message #{$messageId} correctly handled", [
-                'direction' => 'receive',
-                'body' => $amqpMessage->getBody(),
-            ]);
-        } catch (Throwable $throwable) {
-            $this->logger->debug('Cannot handle message', [
-                'exception' => $throwable,
-            ]);
-            $this->channelContainer->getChannel()
-                ->basic_nack($messageId, false, true);
-        }
+        $this->config->handler()
+            ->handle($message);
+        $this->channelContainer->getChannel()
+            ->basic_ack($messageId);
+        $this->logger->info("Message #{$messageId} correctly handled", [
+            'direction' => 'receive',
+            'body' => $amqpMessage->getBody(),
+        ]);
     }
 }