AmqpTransport::send() - Code Metrics - Inspection of "Added testcase for 0 as additional data key" - bzikarsky/gelf-php - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Push — master ( 4502a3...14b87a )

by Benjamin

created 2020-04-24 05:38 UTC

AmqpTransport::send() A

↳ Parent: AmqpTransport

Complexity

Conditions	2
Paths	2

Size

Total Lines	20
Code Lines	11

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	10
CRAP Score	2.0185

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	2
eloc	11
c	1
b	0
f	0
nc	2
nop	1
dl	0
loc	20
ccs	10
cts	12
cp	0.8333
crap	2.0185
rs	9.9

<?php

/*
 * This file is part of the php-gelf package.
 *
 * (c) Benjamin Zikarsky <http://benjamin-zikarsky.de>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 */

namespace Gelf\Transport;

use AMQPExchange;
use AMQPQueue;
use Gelf\Encoder\JsonEncoder as DefaultEncoder;
use Gelf\MessageInterface as Message;

/**
 * Class AmqpTransport
 *
 * @package Gelf\Transport
 * @see http://php.net/manual/pl/book.amqp.php
 */
class AmqpTransport extends AbstractTransport
{
    /**
     * @var AMQPExchange $exchange
     */
    protected $exchange;

    /**
     * @var AMQPQueue $exchange
     */
    protected $queue;

    /**
     * @param AMQPExchange $exchange
     * @param AMQPQueue $queue
     */
    public function __construct(AMQPExchange $exchange, AMQPQueue $queue)
    {
        $this->queue = $queue;
        $this->exchange = $exchange;
        $this->messageEncoder = new DefaultEncoder();
    }

    /**
     * @inheritdoc
     */
    public function send(Message $message)
    {
        $rawMessage = $this->getMessageEncoder()->encode($message);

        $attributes = array(
            'Content-type' => 'application/json'
        );

        // if queue is durable then mark message as 'persistent'
        if (($this->queue->getFlags() & AMQP_DURABLE) > 0) {
            $attributes['delivery_mode'] = 2;
        }

        $this->exchange->publish(
            $rawMessage,
            $this->queue->getName(),
            AMQP_NOPARAM,
            $attributes
        );
        return 1;
    }
}


1		<?php
2
3		/*
4		* This file is part of the php-gelf package.
5		*
6		* (c) Benjamin Zikarsky <http://benjamin-zikarsky.de>
7		*
8		* For the full copyright and license information, please view the LICENSE
9		* file that was distributed with this source code.
10		*/
11
12		namespace Gelf\Transport;
13
14		use AMQPExchange;
15		use AMQPQueue;
16		use Gelf\Encoder\JsonEncoder as DefaultEncoder;
17		use Gelf\MessageInterface as Message;
18
19		/**
20		* Class AmqpTransport
21		*
22		* @package Gelf\Transport
23		* @see http://php.net/manual/pl/book.amqp.php
24		*/
25		class AmqpTransport extends AbstractTransport
26		{
27		/**
28		* @var AMQPExchange $exchange
29		*/
30		protected $exchange;
31
32		/**
33		* @var AMQPQueue $exchange
34		*/
35		protected $queue;
36
37		/**
38		* @param AMQPExchange $exchange
39		* @param AMQPQueue $queue
40		*/
41	4	public function __construct(AMQPExchange $exchange, AMQPQueue $queue)
42		{
43	4	$this->queue = $queue;
44	4	$this->exchange = $exchange;
45	4	$this->messageEncoder = new DefaultEncoder();
46	4	}
47
48		/**
49		* @inheritdoc
50		*/
51	1	public function send(Message $message)
52		{
53	1	$rawMessage = $this->getMessageEncoder()->encode($message);
54
55		$attributes = array(
56		'Content-type' => 'application/json'
57	1	);
58
59		// if queue is durable then mark message as 'persistent'
60	1	if (($this->queue->getFlags() & AMQP_DURABLE) > 0) {
61		$attributes['delivery_mode'] = 2;
62		}
63
64	1	$this->exchange->publish(
65	1	$rawMessage,
66	1	$this->queue->getName(),
67	1	AMQP_NOPARAM,
68		$attributes
69	1	);
70	1	return 1;
71		}
72		}
73

bzikarsky / gelf-php

Push — master ( 4502a3...14b87a )

AmqpTransport::send() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like