RabbitMqModule\Controller\RpcServerController

Complexity

Total Complexity

2

Size/Duplication

Total Lines	35
Duplicated Lines	0 %

Test Coverage

Coverage

100%

Importance

Changes

0

1 Method

Rating	Name	Duplication	Size	Complexity
B	indexAction()	0	27	2

<?php

namespace RabbitMqModule\Controller;

use Zend\Console\ColorInterface;

/**
 * Class RpcServerController
 *
 * @package RabbitMqModule\Controller
 */
class RpcServerController extends AbstractConsoleController
{
    /**
     * Default action if none provided
     *
     * @return \Zend\Console\Response
     */
    public function indexAction()
    {
        /** @var \Zend\Console\Request $request */
        $request = $this->getRequest();
        /** @var \Zend\Console\Response $response */
        $response = $this->getResponse();

        $this->getConsole()->writeLine(sprintf('Starting rpc server %s', $request->getParam('name')));

        $serviceName = sprintf('rabbitmq_module.rpc_server.%s', $request->getParam('name'));

        if (!$this->container->has($serviceName)) {
            $this->getConsole()->writeLine(
                sprintf('No rpc server with name "%s" found', $request->getParam('name')),
                ColorInterface::RED
            );
            $response->setErrorLevel(1);

            return $response;
        }

        /** @var \RabbitMqModule\RpcServer $consumer */
        $consumer = $this->container->get($serviceName);
        $consumer->consume();

        return $response;
    }
}