graze / queue

        $this->handler = new NullAcknowledgementHandler();

    }

    public function testHandle()

    {

        $handler = $this->handler;

        $this->messageA->shouldReceive('isValid')->once()->withNoArgs()->andReturn(true);

        $this->messageB->shouldReceive('isValid')->once()->withNoArgs()->andReturn(true);

        $this->messageC->shouldReceive('isValid')->once()->withNoArgs()->andReturn(true);

        $msgs = [];

        $handler($this->messages, $this->adapter, function ($msg) use (&$msgs) {

            $msgs[] = $msg;

        });

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

    }

    public function testHandleInvalidMessage()

    {

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

    }

    public function testHandleInvalidMessage()

    {

        $handler = $this->handler;

        $this->messageA->shouldReceive('isValid')->once()->withNoArgs()->andReturn(true);

        $this->messageB->shouldReceive('isValid')->once()->withNoArgs()->andReturn(false);

        $this->messageC->shouldReceive('isValid')->once()->withNoArgs()->andReturn(true);

        $msgs = [];

        $handler($this->messages, $this->adapter, function ($msg) use (&$msgs) {

            $msgs[] = $msg;

        });

        assertThat($msgs, is(identicalTo([$this->messageA, $this->messageC])));

    }

    public function testHandleWorkerWithThrownException()

    {