Extraload\Loader\MessageLoader

Complexity

Total Complexity

3

Size/Duplication

Total Lines	20
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	5
Bugs	1	Features	0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	load()	0	10	2

<?php

namespace Extraload\Loader;

use Extraload\Loader\LoaderInterface;

class MessageLoader extends AutoFlushLoader implements LoaderInterface
{
    private $loader;

    public function __construct(LoaderInterface $loader)
    {
        $this->loader = $loader;
    }

    public function load($data = null)
    {
        if (!$data instanceof \AMQPEnvelope) {
            throw new \InvalidArgumentException('MessageLoader can only load AMQPEnvelope.');
        }

        $this->loader->load(unserialize($data->getBody()));

        $this->loader->flush();
    }
}