Saxulum\MessageQueue\SystemV\SystemVReceive

Complexity

Total Complexity

4

Size/Duplication

Total Lines	75
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	9	1
B	receive()	0	31	3

<?php

namespace Saxulum\MessageQueue\SystemV;

use Saxulum\MessageQueue\MessageInterface;
use Saxulum\MessageQueue\MessageReceiveInterface;

final class SystemVReceive implements MessageReceiveInterface
{
    /**
     * @var string
     */
    private $messageClass;

    /**
     * @var resource
     */
    private $queue;

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

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

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

        msg_set_queue($this->queue, ['msg_qbytes' => $this->qbytes]);
    }

    /**
     * @return null|MessageInterface
     *
     * @throws \Exception
     */
    public function receive()
    {
        $type = null;
        $json = null;
        $errorCode = null;

        $status = msg_receive(
            $this->queue,
            $this->type,
            $type,
            $this->qbytes / 2,
            $json,
            false,
            MSG_IPC_NOWAIT,
            $errorCode
        );

        if (false === $status) {
            // we do not wait for a message (prevent lock)
            if (MSG_ENOMSG === $errorCode) {
                return null;
            }

            throw new \Exception(sprintf('Can\'t receive message, error code %d', $errorCode), $errorCode);
        }

        /** @var MessageInterface $messageClass */
        $messageClass = $this->messageClass;

        return $messageClass::fromJson($json);
    }
}