AmqpTransport::send() - Code Metrics - bzikarsky/gelf-php - Measure and Improve Code Quality continuously with Scrutinizer

AmqpTransport::send() A
last analyzed 2025-01-20 15:21 UTC

↳ Parent: AmqpTransport

Complexity

Conditions	2
Paths	2

Size

Total Lines	20
Code Lines	11

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	6

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
rs	9.9
ccs	0
cts	12
cp	0
crap	6

<?php
declare(strict_types=1);

/*
 * 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
{
    public function __construct(
        private AMQPExchange $exchange,
        private AMQPQueue $queue
    ) {
        parent::__construct();
    }

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

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

bzikarsky / gelf-php

AmqpTransport::send() A last analyzed 2025-01-20 15:21 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

AmqpTransport::send() A
last analyzed 2025-01-20 15:21 UTC