PendingDispatch::onQueue() - Code Metrics - bakaphp/canvas-core - Measure and Improve Code Quality continuously with Scrutinizer

PendingDispatch::onQueue() A
last analyzed 2020-06-20 15:42 UTC

↳ Parent: PendingDispatch

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
cc	1
eloc	2
nc	1
nop	1
dl	0
loc	4
rs	10
c	0
b	0
f	0

<?php

declare(strict_types=1);

namespace Canvas\Jobs;

use Canvas\Contracts\Queue\QueueableJobInterface;
use Canvas\Queue\Queue;
use Phalcon\Di;

class PendingDispatch
{
    /**
     * The job.
     *
     * @var mixed
     */
    protected $job;

    /**
     * Create a new pending job dispatch.
     *
     * @param  QueueableJobInterface  $job
     * @return void
     */
    public function __construct(QueueableJobInterface $job)
    {
        $this->job = $job;
    }

    /**
     * Set the desired queue for the job.
     *
     * @param  string  $queue
     * @return $this
     */
    public function onQueue(string $queue)
    {
        $this->job->onQueue($queue);
        return $this;
    }

    /**
     * Handle the object's destruction.
     *
     * @return void
     */
    public function __destruct()
    {
        $jobData = [
            'userData' => Di::getDefault()->getUserData(),
            'class' => get_class($this->job),
            'job' => $this->job
        ];

        return Queue::send($this->job->queue, serialize($jobData));

    }
}


1			<?php
2
3			declare(strict_types=1);
4
5			namespace Canvas\Jobs;
6
7			use Canvas\Contracts\Queue\QueueableJobInterface;
8			use Canvas\Queue\Queue;
9			use Phalcon\Di;
10
11			class PendingDispatch
12			{
13			/**
14			* The job.
15			*
16			* @var mixed
17			*/
18			protected $job;
19
20			/**
21			* Create a new pending job dispatch.
22			*
23			* @param QueueableJobInterface $job
24			* @return void
25			*/
26			public function __construct(QueueableJobInterface $job)
27			{
28			$this->job = $job;
29			}
30
31			/**
32			* Set the desired queue for the job.
33			*
34			* @param string $queue
35			* @return $this
36			*/
37			public function onQueue(string $queue)
38			{
39			$this->job->onQueue($queue);
40			return $this;
41			}
42
43			/**
44			* Handle the object's destruction.
45			*
46			* @return void
47			*/
48			public function __destruct()
49			{
50			$jobData = [
51			'userData' => Di::getDefault()->getUserData(),
52			'class' => get_class($this->job),
53			'job' => $this->job
54			];
55
56			return Queue::send($this->job->queue, serialize($jobData));
			0 ignored issues – show Bug Best Practice introduced 2020-04-02 15:50 UTC by Report Bug Copy Issue Report The expression `return Canvas\Queue\Queu...e, serialize($jobData))` returns the type `true` which is incompatible with the documented return type `void`. Loading history...
57			}
58			}
59

bakaphp / canvas-core

PendingDispatch::onQueue() A last analyzed 2020-06-20 15:42 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

PendingDispatch::onQueue() A
last analyzed 2020-06-20 15:42 UTC