Graze\Queue\ArrayIntegrationTest

Complexity

Total Complexity

8

Size/Duplication

Total Lines	93
Duplicated Lines	66.67 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes	1
Bugs	0	Features	0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	setUp()	0	12	1
A	testReceive()	9	9	1
A	testReceiveWithPolling()	9	9	1
A	testReceiveWithNoMessages()	11	11	1
A	testReceiveWithLimitAndNoMessages()	11	11	1
A	testSend()	0	4	1
A	testPurge()	11	11	1
A	testDelete()	11	11	1

<?php

/**
 * This file is part of graze/queue.
 *
 * Copyright (c) 2015 Nature Delivered Ltd. <https://www.graze.com>
 *
 * For the full copyright and license information, please view the LICENSE
 * file that was distributed with this source code.
 *
 * @license https://github.com/graze/queue/blob/master/LICENSE MIT
 *
 * @link    https://github.com/graze/queue
 */

namespace Graze\Queue;

use Graze\Queue\Adapter\ArrayAdapter;
use Graze\Queue\Message\MessageFactory;
use Graze\Queue\Message\MessageInterface;
use PHPUnit_Framework_TestCase as TestCase;

class ArrayIntegrationTest extends TestCase
{
    /** @var MessageInterface[] */
    private $messages;
    /** @var Client */
    private $client;

    public function setUp()
    {
        $factory = new MessageFactory();

        $this->messages = [
            $factory->createMessage('foo'),
            $factory->createMessage('bar'),
            $factory->createMessage('baz'),
        ];

        $this->client = new Client(new ArrayAdapter($this->messages));
    }

    public function testReceive()

This method seems to be duplicated in your project.

    {
        $msgs = [];
        $this->client->receive(function ($msg) use (&$msgs) {
            $msgs[] = $msg;
        }, 100);

        assertThat($msgs, is(identicalTo($this->messages)));
    }

    public function testReceiveWithPolling()

This method seems to be duplicated in your project.

    {
        $msgs = [];
        $this->client->receive(function ($msg) use (&$msgs) {
            $msgs[] = $msg;
        }, null);

        assertThat($msgs, is(identicalTo($this->messages)));
    }

    public function testReceiveWithNoMessages()

This method seems to be duplicated in your project.

    {
        $client = new Client(new ArrayAdapter());

        $msgs = [];
        $client->receive(function ($msg) use (&$msgs) {
            $msgs[] = $msg;
        }, null);

        assertThat($msgs, is(emptyArray()));
    }

    public function testReceiveWithLimitAndNoMessages()

This method seems to be duplicated in your project.

    {
        $client = new Client(new ArrayAdapter());

        $msgs = [];
        $client->receive(function ($msg) use (&$msgs) {
            $msgs[] = $msg;
        }, 10);

        assertThat($msgs, is(emptyArray()));
    }

    public function testSend()
    {
        $this->client->send([$this->client->create('foo')]);
    }

    public function testPurge()

This method seems to be duplicated in your project.

    {
        $this->client->purge();

        $msgs = [];
        $this->client->receive(function ($msg) use (&$msgs) {
            $msgs[] = $msg;
        }, null);

        assertThat($msgs, is(emptyArray()));
    }

    public function testDelete()

This method seems to be duplicated in your project.

    {
        $this->client->delete();

        $msgs = [];
        $this->client->receive(function ($msg) use (&$msgs) {
            $msgs[] = $msg;
        }, null);

        assertThat($msgs, is(emptyArray()));
    }
}