graze / queue

    /** @var ArrayAdapter */

    private $adapter;

    public function setUp()

    {

        $this->factory = m::mock(MessageFactoryInterface::class);

        $this->messageA = $a = m::mock(MessageInterface::class);

        $this->messageB = $b = m::mock(MessageInterface::class);

        $this->messageC = $c = m::mock(MessageInterface::class);

        $this->messages = [$a, $b, $c];

        $this->adapter = new ArrayAdapter($this->messages);

    }

    public function testInterface()

    {

    /** @var BatchAcknowledgementHandler */

    private $handler;

    public function setUp()

    {

        $this->adapter = m::mock(AdapterInterface::class);

        $this->messageA = $a = m::mock(MessageInterface::class);

        $this->messageB = $b = m::mock(MessageInterface::class);

        $this->messageC = $c = m::mock(MessageInterface::class);

        $this->messages = new ArrayIterator([$a, $b, $c]);

        $this->handler = new BatchAcknowledgementHandler(3);

    }

    public function testHandle()

    {

    /** @var EagerAcknowledgementHandler */

    private $handler;

    public function setUp()

    {

        $this->adapter = m::mock(AdapterInterface::class);

        $this->messageA = $a = m::mock(MessageInterface::class);

        $this->messageB = $b = m::mock(MessageInterface::class);

        $this->messageC = $c = m::mock(MessageInterface::class);

        $this->messages = new ArrayIterator([$a, $b, $c]);

        $this->handler = new EagerAcknowledgementHandler();

    }

    public function testHandle()

    {