pascualmg/DropExceptionWhenMiddleware.php

<?php

declare(strict_types=1);

namespace PcComponentes\AfterSales\Infrastructure\MessagingMiddleware;

use Symfony\Component\Messenger\Envelope;
use Symfony\Component\Messenger\Exception\UnrecoverableExceptionInterface;
use Symfony\Component\Messenger\Middleware\MiddlewareInterface;
use Symfony\Component\Messenger\Middleware\StackInterface;
use Symfony\Component\Messenger\Transport\AmqpExt\AmqpReceivedStamp;

class ExpectedExceptionMiddleware implements MiddlewareInterface
{
    public function handle(Envelope $envelope, StackInterface $stack): Envelope
    {
        $isFromConsumer = static fn (Envelope $envelope) => $envelope->all(AmqpReceivedStamp::class) !== [];

        if (false === $isFromConsumer($envelope)) {
            return $stack->next()->handle($envelope, $stack);
        }

        try {
            return $stack->next()->handle($envelope, $stack);
        } catch (UnrecoverableExceptionInterface $unrecoverableException) {
            return $envelope;
        }
    }
}