queue/src/InteractsWithQueueableAttributes.php at 8d52dd0ba0bdb8a6199de0d59c4f71bddd047792 · techmahedy/queue · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
<?php

namespace Doppar\Queue;

use Doppar\Queue\Attributes\Queueable;

trait InteractsWithQueueableAttributes
{
    /**
     * Check if the job should be queued based on the Queueable attribute.
     *
     * @return bool
     */
    public function shouldQueue(): bool
    {
        $reflection = new \ReflectionClass($this);
        $attributes = $reflection->getAttributes(Queueable::class);

        return !empty($attributes);
    }

    /**
     * Apply the Queueable attribute settings to the job.
     *
     * @return void
     */
    protected function applyQueueableAttributes(): void
    {
        $reflection = new \ReflectionClass($this);
        $attributes = $reflection->getAttributes(Queueable::class);

        if (!empty($attributes)) {
            $attribute = $attributes[0]->newInstance();

            if ($attribute->tries !== null) {
                $this->tries = $attribute->tries;
            }

            if ($attribute->retryAfter !== null) {
                $this->retryAfter = $attribute->retryAfter;
            }

            if ($attribute->delayFor !== null) {
                $this->jobDelay = $attribute->delayFor;
            }

            if ($attribute->onQueue !== null) {
                $this->queueName = $attribute->onQueue;
            }

            if ($attribute->timeout !== null) {
                $this->timeout = $attribute->timeout;
            }
        }
    }
}