vendor/shopware/core/Framework/MessageQueue/Handler/AbstractMessageHandler.php line 21

Open in your IDE?
  1. <?php declare(strict_types=1);
  3. namespace Shopware\Core\Framework\MessageQueue\Handler;
  5. use Shopware\Core\Framework\Log\Package;
  6. use Shopware\Core\Framework\MessageQueue\Exception\MessageFailedException;
  7. use Symfony\Component\Messenger\Handler\MessageSubscriberInterface;
  9. /**
  10.  * @deprecated tag:v6.5.0 - reason:reason:class-hierarchy-change - will be removed, use default symfony MessageSubscriberInterface instead
  11.  */
  12. #[Package('core')]
  13. abstract class AbstractMessageHandler implements MessageSubscriberInterface
  14. {
  15.     /**
  16.      * @param object $message
  17.      */
  18.     public function __invoke($message): void
  19.     {
  20.         try {
  21.             $this->handle($message);
  22.         } catch (MessageFailedException $messageFailedException) {
  23.             throw $messageFailedException;
  24.         } catch (\Throwable $e) {
  25.             throw new MessageFailedException($message, static::class, $e);
  26.         }
  27.     }
  29.     /**
  30.      * @param object $message
  31.      */
  32.     abstract public function handle($message): void;
  34.     /**
  35.      * @return iterable<int|string>
  36.      */
  37.     abstract public static function getHandledMessages(): iterable;
  38. }