TestRabbitMq\Consumers\ConsumerA

Complexity

Total Complexity

3

Size/Duplication

Total Lines	23
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	1
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	execute()	0	8	1
A	getMessages()	0	4	1
A	flushMessages()	0	4	1

<?php

namespace TestRabbitMq\Consumers;

use OldSound\RabbitMqBundle\RabbitMq\ConsumerInterface;
use PhpAmqpLib\Message\AMQPMessage;

use Silex\Applications;

class ConsumerA implements ConsumerInterface
{
    private $messages = [];

    public function execute(AMQPMessage $message)
    {
        $payload = json_decode($message->body, true);

        $this->messages[] = $payload;

        return true;
    }

    public function getMessages()
    {
        return $this->messages;
    }

    public function flushMessages()
    {
        $this->messages = [];
    }
}