Producer::produce() - Code Metrics - Inspection of "Merge pull request #406 from holtkamp/dev-patch-sy..." - bernardphp/bernard - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( eab0f2...fee417 )

by Jeroen

created 2019-10-20 16:07 UTC

Producer::produce() A

↳ Parent: Producer

Complexity

Conditions	2
Paths	2

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	6
CRAP Score	2.0116

Importance

Changes

Metric	Value
dl	0
loc	9
ccs	6
cts	7
cp	0.8571
rs	9.9666
c	0
b	0
f	0
cc	2
nc	2
nop	2
crap	2.0116

<?php

namespace Bernard;

use Bernard\Event\EnvelopeEvent;
use Symfony\Component\EventDispatcher\EventDispatcherInterface;

class Producer
{
    protected $queues;
    protected $dispatcher;

    /**
     * @param QueueFactory             $queues
     * @param EventDispatcherInterface $dispatcher
     */
    public function __construct(QueueFactory $queues, EventDispatcherInterface $dispatcher)
    {
        $this->queues = $queues;
        $this->dispatcher = $dispatcher;
    }

    /**
     * @param Message     $message
     * @param string|null $queueName
     */
    public function produce(Message $message, $queueName = null)
    {
        $queueName = $queueName ?: Util::guessQueue($message);

        $queue = $this->queues->create($queueName);
        $queue->enqueue($envelope = new Envelope($message));

        $this->dispatch(BernardEvents::PRODUCE, new EnvelopeEvent($envelope, $queue));
    }

    private function dispatch($eventName, EnvelopeEvent $event)
    {
        $this->dispatcher instanceof \Symfony\Contracts\EventDispatcher\EventDispatcherInterface
           ? $this->dispatcher->dispatch($event, $eventName)
           : $this->dispatcher->dispatch($eventName, $event);
    }
}


1		<?php
2
3		namespace Bernard;
4
5		use Bernard\Event\EnvelopeEvent;
6		use Symfony\Component\EventDispatcher\EventDispatcherInterface;
7
8		class Producer
9		{
10		protected $queues;
11		protected $dispatcher;
12
13		/**
14		* @param QueueFactory $queues
15		* @param EventDispatcherInterface $dispatcher
16		*/
17	3	public function __construct(QueueFactory $queues, EventDispatcherInterface $dispatcher)
18		{
19	3	$this->queues = $queues;
20	3	$this->dispatcher = $dispatcher;
21	3	}
22
23		/**
24		* @param Message $message
25		* @param string\|null $queueName
26		*/
27	3	public function produce(Message $message, $queueName = null)
28		{
29	3	$queueName = $queueName ?: Util::guessQueue($message);
30
31	3	$queue = $this->queues->create($queueName);
32	3	$queue->enqueue($envelope = new Envelope($message));
33
34	3	$this->dispatch(BernardEvents::PRODUCE, new EnvelopeEvent($envelope, $queue));
35	3	}
36
37	3	private function dispatch($eventName, EnvelopeEvent $event)
38		{
39	3	$this->dispatcher instanceof \Symfony\Contracts\EventDispatcher\EventDispatcherInterface
40	3	? $this->dispatcher->dispatch($event, $eventName)
41	3	: $this->dispatcher->dispatch($eventName, $event);
42	3	}
43		}
44

bernardphp / bernard

GitHub Access Token became invalid

Push — master ( eab0f2...fee417 )

Producer::produce() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like