Puzzle\AMQP\Messages\InMemoryJson

Complexity

Total Complexity

9

Size/Duplication

Total Lines	48
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

45.45%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	getRawBody()	0	4	1
A	getDecodedBody()	0	4	1
A	getAttributes()	0	4	1
A	isLastRetry()	0	6	2
A	applyHooks()	0	11	2
A	getRoutingKeyFromHeader()	0	11	2

<?php

namespace Puzzle\AMQP\Messages;

use Puzzle\AMQP\ReadableMessage;
use Puzzle\AMQP\WritableMessage;
use Puzzle\AMQP\Collections\MessageHookCollection;

class InMemoryJson extends Json implements ReadableMessage, WritableMessage
{
    public function getRawBody()
    {
        return $this->getFormattedBody();
    }

    public function getDecodedBody()
    {
        return $this->body;
    }

    public function getAttributes()
    {
        return $this->packAttributes();
    }

    public function isLastRetry($retryOccurence = \Puzzle\AMQP\Consumers\Retry::DEFAULT_RETRY_OCCURENCE)
    {
        $retryHeader = $this->getHeader(\Puzzle\AMQP\Consumers\Retry::DEFAULT_RETRY_HEADER);

The method getHeader() does not exist on Puzzle\AMQP\Messages\InMemoryJson. Did you maybe mean getHeaders()?

        return (!empty($retryHeader) && (int) $retryHeader === $retryOccurence);
    }

    public function applyHooks(MessageHookCollection $messageHookCollection)
    {
        $body = $this->body;

        foreach($messageHookCollection as $hook)
        {
            $body = $hook->process($body);
        }

        $this->body = $body;
    }

    public function getRoutingKeyFromHeader()
    {
        $headers = $this->getHeaders();

        if(! array_key_exists('routing_key', $headers))
        {
            return null;
        }

        return $headers['routing_key'];
    }
}