Cmobi\RabbitmqBundle\Transport\Rpc\RpcQueueCallback

Complexity

Total Complexity

3

Size/Duplication

Total Lines	41
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getQueueService()	0	4	1
A	toClosure()	0	20	1

<?php

namespace Cmobi\RabbitmqBundle\Transport\Rpc;

use Cmobi\RabbitmqBundle\Queue\CmobiAMQPMessage;
use Cmobi\RabbitmqBundle\Queue\QueueCallbackInterface;
use Cmobi\RabbitmqBundle\Queue\QueueServiceInterface;
use PhpAmqpLib\Message\AMQPMessage;

class RpcQueueCallback implements QueueCallbackInterface
{
    private $queueService;

    public function __construct(QueueServiceInterface $queueService)
    {
        $this->queueService = $queueService;
    }

    /**
     * @return QueueServiceInterface
     */
    public function getQueueService()
    {
        return $this->queueService;
    }

    /**
     * @return \Closure
     */
    public function toClosure()
    {
        return function (AMQPMessage $message) {
            $response = $this->getQueueService()->handle($message);

            $amqpResponse = new CmobiAMQPMessage(
                (string) $response,
                ['correlation_id' => $message->get('correlation_id')]
            );

            $message->delivery_info['channel']->basic_publish(
                $amqpResponse,
                '',
                $message->get('reply_to')
            );
            $message->delivery_info['channel']->basic_ack(
                $message->delivery_info['delivery_tag']

$message->delivery_info['delivery_tag'] is of type object<PhpAmqpLib\Channel\AMQPChannel>, but the function expects a string.

            );
        };
    }
}