SystemVSend::send() - Code Metrics - saxulum/saxulum-message-queue - Measure and Improve Code Quality continuously with Scrutinizer

SystemVSend::send() A
last analyzed 2018-04-20 17:02 UTC

↳ Parent: SystemVSend

Complexity

Conditions	2
Paths	2

Size

Total Lines	14
Code Lines	8

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	14
c	0
b	0
f	0
rs	9.4285
cc	2
eloc	8
nc	2
nop	1

<?php

namespace Saxulum\MessageQueue\SystemV;

use Saxulum\MessageQueue\MessageInterface;
use Saxulum\MessageQueue\MessageSendException;
use Saxulum\MessageQueue\MessageSendInterface;

final class SystemVSend implements MessageSendInterface
{
    /**
     * @var resource
     */
    private $queue;

    /**
     * @var int
     */
    private $type;

    /**
     * @param int $key
     * @param int $type
     */
    public function __construct(int $key, int $type = 1)
    {
        $this->queue = msg_get_queue($key);
        $this->type = $type;
    }

    /**
     * @param MessageInterface $message
     *
     * @return MessageSendInterface
     *
     * @throws MessageSendException
     */
    public function send(MessageInterface $message): MessageSendInterface
    {
        $errorCode = null;
        $json = $message->toJson();

        if (false === msg_send($this->queue, $this->type, $json, false, true, $errorCode)) {
            throw new MessageSendException(
                sprintf(MessageSendException::MESSAGE_SEND_FAILED, sprintf(' (SystemV error code %d)', $errorCode)),
                MessageSendException::CODE_SEND_FAILED
            );
        }

        return $this;
    }
}


1			<?php
2
3			namespace Saxulum\MessageQueue\SystemV;
4
5			use Saxulum\MessageQueue\MessageInterface;
6			use Saxulum\MessageQueue\MessageSendException;
7			use Saxulum\MessageQueue\MessageSendInterface;
8
9			final class SystemVSend implements MessageSendInterface
10			{
11			/**
12			* @var resource
13			*/
14			private $queue;
15
16			/**
17			* @var int
18			*/
19			private $type;
20
21			/**
22			* @param int $key
23			* @param int $type
24			*/
25			public function __construct(int $key, int $type = 1)
26			{
27			$this->queue = msg_get_queue($key);
28			$this->type = $type;
29			}
30
31			/**
32			* @param MessageInterface $message
33			*
34			* @return MessageSendInterface
35			*
36			* @throws MessageSendException
37			*/
38			public function send(MessageInterface $message): MessageSendInterface
39			{
40			$errorCode = null;
41			$json = $message->toJson();
42
43			if (false === msg_send($this->queue, $this->type, $json, false, true, $errorCode)) {
44			throw new MessageSendException(
45			sprintf(MessageSendException::MESSAGE_SEND_FAILED, sprintf(' (SystemV error code %d)', $errorCode)),
46			MessageSendException::CODE_SEND_FAILED
47			);
48			}
49
50			return $this;
51			}
52			}
53

saxulum / saxulum-message-queue

SystemVSend::send() A last analyzed 2018-04-20 17:02 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

SystemVSend::send() A
last analyzed 2018-04-20 17:02 UTC