Subversion-Projekte lars-tiefland.laravel_shop

Revision

Revision 150 | Ganze Datei anzeigen | Leerzeichen ignorieren | Details | Blame | Letzte Änderung | Log anzeigen | RSS feed

Revision 150 Revision 200
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 32... Zeile 31...
32
 
31
 
33
    /** @var StampInterface[] */
32
    /** @var StampInterface[] */
Zeile 34... Zeile 33...
34
    private array $stamps = [];
33
    private array $stamps = [];
Zeile 69... Zeile 68...
69
    public function isQueued(): bool
68
    public function isQueued(): bool
70
    {
69
    {
71
        return $this->queued;
70
        return $this->queued;
72
    }
71
    }
Zeile 73... Zeile -...
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
    }
-
 
84
 
72
 
85
    public function addStamp(StampInterface $stamp): void
73
    public function addStamp(StampInterface $stamp): void
86
    {
74
    {
87
        if (!$this->queued) {
75
        if (!$this->queued) {
88
            throw new LogicException(sprintf('Cannot call "%s()" on a message that is not meant to be queued.', __METHOD__));
76
            throw new LogicException(sprintf('Cannot call "%s()" on a message that is not meant to be queued', __METHOD__));
Zeile 89... Zeile 77...
89
        }
77
        }
90
 
78