Subversion-Projekte lars-tiefland.laravel_shop

Revision

Revision 148 | Zur aktuellen Revision | Ganze Datei anzeigen | Leerzeichen ignorieren | Details | Blame | Letzte Änderung | Log anzeigen | RSS feed

Revision 148 Revision 150
Zeile 26... Zeile 26...
26
{
26
{
27
    private RawMessage $message;
27
    private RawMessage $message;
28
    private Envelope $envelope;
28
    private Envelope $envelope;
29
    private string $transport;
29
    private string $transport;
30
    private bool $queued;
30
    private bool $queued;
-
 
31
    private bool $rejected = false;
Zeile 31... Zeile 32...
31
 
32
 
32
    /** @var StampInterface[] */
33
    /** @var StampInterface[] */
Zeile 33... Zeile 34...
33
    private array $stamps = [];
34
    private array $stamps = [];
Zeile 68... Zeile 69...
68
    public function isQueued(): bool
69
    public function isQueued(): bool
69
    {
70
    {
70
        return $this->queued;
71
        return $this->queued;
71
    }
72
    }
Zeile -... Zeile 73...
-
 
73
 
-
 
74
    public function isRejected(): bool
-
 
75
    {
-
 
76
        return $this->rejected;
-
 
77
    }
-
 
78
 
-
 
79
    public function reject(): void
-
 
80
    {
-
 
81
        $this->rejected = true;
-
 
82
        $this->stopPropagation();
-
 
83
    }
72
 
84
 
73
    public function addStamp(StampInterface $stamp): void
85
    public function addStamp(StampInterface $stamp): void
74
    {
86
    {
75
        if (!$this->queued) {
87
        if (!$this->queued) {
76
            throw new LogicException(sprintf('Cannot call "%s()" on a message that is not meant to be queued', __METHOD__));
88
            throw new LogicException(sprintf('Cannot call "%s()" on a message that is not meant to be queued.', __METHOD__));
Zeile 77... Zeile 89...
77
        }
89
        }
78
 
90