vendor/symfony/messenger/Stamp/AckStamp.php line 19

Open in your IDE?
  1. <?php
  3. /*
  4.  * This file is part of the Symfony package.
  5.  *
  6.  * (c) Fabien Potencier <fabien@symfony.com>
  7.  *
  8.  * For the full copyright and license information, please view the LICENSE
  9.  * file that was distributed with this source code.
  10.  */
  12. namespace Symfony\Component\Messenger\Stamp;
  14. use Symfony\Component\Messenger\Envelope;
  16. /**
  17.  * Marker stamp for messages that can be ack/nack'ed.
  18.  */
  19. final class AckStamp implements NonSendableStampInterface
  20. {
  21.     private $ack;
  23.     /**
  24.      * @param \Closure(Envelope, \Throwable|null) $ack
  25.      */
  26.     public function __construct(\Closure $ack)
  27.     {
  28.         $this->ack = $ack;
  29.     }
  31.     public function ack(Envelope $envelope, \Throwable $e = null): void
  32.     {
  33.         ($this->ack)($envelope, $e);
  34.     }
  35. }