AmqpMessagePublisher::__construct() - Code Metrics - Inspection of "Je veux scaler avec un système de message queue" - jean-pasqualini/import - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Pull Request — 0.4 (#35)

by jean

created 2018-07-15 09:59 UTC

AmqpMessagePublisher::__construct() A

↳ Parent: AmqpMessagePublisher

Complexity

Conditions	1
Paths	1

Size

Total Lines	9
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	2

Importance

Changes

Metric	Value
cc	1
eloc	6
nc	1
nop	4
dl	0
loc	9
ccs	0
cts	8
cp	0
crap	2
rs	10
c	0
b	0
f	0

<?php

namespace Darkilliant\MqProcessBundle\Message\Publisher;

use PhpAmqpLib\Channel\AMQPChannel;
use PhpAmqpLib\Message\AMQPMessage;

class AmqpMessagePublisher
{
    /** @var AMQPChannel */
    private $channel;
    /** @var string */
    private $queue;
    /** @var string */
    private $exchange;
    /** @var int */
    private $batch = 0;
    /** @var bool */
    private $persistant;

    public function __construct(AMQPChannel $channel, string $queue, string $exchange, bool $persistant)
    {
        $this->channel = $channel;
        $this->queue = $queue;
        $this->exchange = $exchange;
        $this->persistant = $persistant;

        $this->channel->queue_declare($this->queue, false, $this->persistant);
        $this->channel->queue_bind($this->queue, $this->exchange, $this->queue);
    }

    public function publish(string $message, int $batchCount)
    {
        ++$this->batch;
        $this->channel->batch_basic_publish(new AMQPMessage($message), $this->exchange, $this->queue);

        if ($this->batch >= $batchCount) {
            $this->flush();
        }
    }

    public function finalize()
    {
        $this->flush();
    }

    public function flush()
    {
        $this->channel->publish_batch();
    }

    public function countMessages(): int
    {
        return $this->channel->queue_declare($this->queue, true)->messageCount;
    }
}


1			<?php
2
3			namespace Darkilliant\MqProcessBundle\Message\Publisher;
4
5			use PhpAmqpLib\Channel\AMQPChannel;
6			use PhpAmqpLib\Message\AMQPMessage;
7
8			class AmqpMessagePublisher
9			{
10			/** @var AMQPChannel */
11			private $channel;
12			/** @var string */
13			private $queue;
14			/** @var string */
15			private $exchange;
16			/** @var int */
17			private $batch = 0;
18			/** @var bool */
19			private $persistant;
20
21			public function __construct(AMQPChannel $channel, string $queue, string $exchange, bool $persistant)
22			{
23			$this->channel = $channel;
24			$this->queue = $queue;
25			$this->exchange = $exchange;
26			$this->persistant = $persistant;
27
28			$this->channel->queue_declare($this->queue, false, $this->persistant);
29			$this->channel->queue_bind($this->queue, $this->exchange, $this->queue);
30			}
31
32			public function publish(string $message, int $batchCount)
33			{
34			++$this->batch;
35			$this->channel->batch_basic_publish(new AMQPMessage($message), $this->exchange, $this->queue);
36
37			if ($this->batch >= $batchCount) {
38			$this->flush();
39			}
40			}
41
42			public function finalize()
43			{
44			$this->flush();
45			}
46
47			public function flush()
48			{
49			$this->channel->publish_batch();
50			}
51
52			public function countMessages(): int
53			{
54			return $this->channel->queue_declare($this->queue, true)->messageCount;
55			}
56			}
57

jean-pasqualini / import

Pull Request — 0.4 (#35)

AmqpMessagePublisher::__construct() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like