Governor\Bundle\GovernorBundle\Command\AmqpDebugCommand

Complexity

Total Complexity

3

Size/Duplication

Total Lines	92
Duplicated Lines	18.48 %

Coupling/Cohesion

Components	0
Dependencies	3

Test Coverage

Coverage

0%

Importance

Changes	2
Bugs	0	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	configure()	17	17	1
A	execute()	0	69	2

<?php

/*
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
 * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
 *
 * The software is based on the Axon Framework project which is
 * licensed under the Apache 2.0 license. For more information on the Axon Framework
 * see <http://www.axonframework.org/>.
 * 
 * This software consists of voluntary contributions made by many individuals
 * and is licensed under the MIT license. For more information, see
 * <http://www.governor-framework.org/>.
 */

namespace Governor\Bundle\GovernorBundle\Command;

use Symfony\Component\Console\Input\InputInterface;
use Symfony\Component\Console\Input\InputArgument;
use Symfony\Component\Console\Output\OutputInterface;
use Symfony\Bundle\FrameworkBundle\Command\ContainerAwareCommand;
use Governor\Framework\EventHandling\Io\EventMessageReader;

/**
 * Description of AmqpDebugCommand
 *
 * @author david
 */
class AmqpDebugCommand extends ContainerAwareCommand
{

    protected function configure()

This method seems to be duplicated in your project.

    {
        $this
            ->setName('governor:amqp-debug')
            ->addArgument(
                "exchange",
                InputArgument::REQUIRED,
                "Name of the exchange to listen read from"
            )
            ->addArgument(
                "connection",
                InputArgument::OPTIONAL,
                "Name of the connection to use",
                "default"
            )
            ->setDescription('Displays events routed to the AMQP terminal.');
    }

    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $formatter = $this->getHelperSet()->get('formatter');
        $serializer = $this->getContainer()->get('governor.serializer');
        $connection = $this->getContainer()->get(
            sprintf(
                "governor.amqp_terminal.connection.%s",
                $input->getArgument("connection")
            )
        );

        $channel = $connection->channel();

        $output->writeln(
            $formatter->formatSection(
                'Connecting',
                'Using connection '.$input->getArgument('connection')
            )
        );

        list($queueName, ,) = $channel->queue_declare(
            "",
            false,
            false,
            true,
            false
        );
        $channel->queue_bind($queueName, $input->getArgument('exchange'), '#');

        $output->writeln(
            $formatter->formatSection(
                '*',
                'Waiting for events. To exit press CTRL+C'
            )
        );

        $callback = function ($msg) use ($output, $formatter, $serializer) {
            $reader = new EventMessageReader($serializer);
            $message = $reader->readEventMessage($msg->body);

            $output->writeln(
                $formatter->formatSection(
                    '*',
                    sprintf(
                        "Recieved event with routing key %s",
                        $msg->delivery_info['routing_key']
                    )
                )
            );
            $output->writeln(array(' [x] '.print_r($message, true)));
        };

        $channel->basic_consume(
            $queueName,
            '',
            false,
            true,
            false,
            false,
            $callback
        );

        while (count($channel->callbacks)) {
            $channel->wait();
        }

        $channel->close();
        $connection->close();
    }

}