Puzzle\AMQP\Clients\InMemory

Complexity

Total Complexity

8

Size/Duplication

Total Lines	61
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	4

Test Coverage

Coverage

100%

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	publish()	0	7	1
A	updateMessageAttributes()	0	7	1
A	getQueue()	0	4	1
A	saveMessage()	0	7	1
A	getSentMessages()	0	4	1
A	dropSentMessages()	0	6	1
A	getExchange()	0	4	1

<?php

namespace Puzzle\AMQP\Clients;

use Puzzle\AMQP\Client;
use Puzzle\AMQP\WritableMessage;
use Psr\Log\NullLogger;
use Puzzle\AMQP\Clients\Processors\MessageProcessorAware;

class InMemory implements Client
{
    use
        \Psr\Log\LoggerAwareTrait,
        MessageProcessorAware;

    private
        $sentMessages;

    public function __construct()
    {
        $this->sentMessages = [];
        $this->logger = new NullLogger();
    }

    public function publish(string $exchangeName, WritableMessage $message): bool
    {
        $this->updateMessageAttributes($message);
        $this->saveMessage($exchangeName, $message);
        
        return true;
    }

    private function updateMessageAttributes(WritableMessage $message): void
    {
        $message->setAttribute('app_id', 'memory');
        $message->addHeader('routing_key', $message->getRoutingKey());
        
        $this->onPublish($message);
    }

    public function getQueue(string $queueName): \AMQPQueue
    {
        throw new \RuntimeException('This AMQP Client must be used only for sending purpose');
    }

    public function getExchange(?string $exchangeName = null, string $type = AMQP_EX_TYPE_TOPIC): \AMQPExchange
    {
        throw new \RuntimeException('This AMQP Client must be used only for sending purpose');
    }

    private function saveMessage($exchangeName, WritableMessage $message)
    {
        $this->sentMessages[] = [
            'exchange' => $exchangeName,
            'message' => $message
        ];
    }

    public function getSentMessages(): array
    {
        return $this->sentMessages;
    }

    public function dropSentMessages(): self
    {
        $this->sentMessages = [];

        return $this;
    }
}