Skip to content
This repository has been archived by the owner on Jun 2, 2023. It is now read-only.

Commit

Permalink
Merge 4f1ade2 into 6974574
Browse files Browse the repository at this point in the history
  • Loading branch information
kovinstanislav committed Jul 2, 2020
2 parents 6974574 + 4f1ade2 commit 82a2ac2
Showing 1 changed file with 5 additions and 3 deletions.
8 changes: 5 additions & 3 deletions src/Consumer.php
Expand Up @@ -80,11 +80,13 @@ public function execute(AMQPMessage $message): int
return $this->doExecute(
$this->queueService->getToProcess($data['id'])
);
} catch (UnexpectedValueException | AttemptsReachedException $exception) {
} catch (UnexpectedValueException $exception) {
$this->logger->alert($exception->getMessage(), $this->getMessageLogParams($message));

return self::MSG_REJECT;
} catch (AttemptsReachedException $exception) {
$this->logger->notice($exception->getMessage(), $this->getMessageLogParams($message));
}

return self::MSG_REJECT;
}

protected function doExecute(QueueEntityInterface $queueEntity): int
Expand Down

0 comments on commit 82a2ac2

Please sign in to comment.