2amigos / mailer-library

        $this->pdoQueueStore = new PdoQueueStoreAdapter(self::getPdoQueueStoreConnection());

    }

    public function testEnqueueDequeueAndAcknowledge()

    {

        $mailJob = FixtureHelper::getMailJob();

        $this->assertSame($this->pdoQueueStore, $this->pdoQueueStore->init());

        $this->assertTrue($this->pdoQueueStore->enqueue($mailJob));

        $this->assertTrue($this->pdoQueueStore->isEmpty() === false);

        $mailJob = $this->pdoQueueStore->dequeue();

        $this->assertTrue($this->pdoQueueStore->isEmpty() === true); // message set to 'A' on process

        $this->assertTrue(!empty($mailJob->getMessage()));

        $dequeuedMailMessage = MailMessage::fromArray(json_decode($mailJob->getMessage(), true));

        $this->assertEquals(FixtureHelper::getMailMessage(), $dequeuedMailMessage);

        $mailJob->markAsCompleted();

        $this->pdoQueueStore->ack($mailJob);

        $this->assertTrue($this->pdoQueueStore->dequeue() === null);

    }

    public function testAcknowledgementToUpdateMailJobs()

    {

        $this->mailQueuePdo = new MailQueue($this->pdoQueueAdapter);

    }

    public function testPdoEnqueDequeueAndAcknowledge()

    {

        $mailJob = FixtureHelper::getMailJob();

        $this->assertSame($this->pdoQueueAdapter, $this->mailQueuePdo->init());

        $this->assertTrue($this->mailQueuePdo->enqueue($mailJob));

        $this->assertTrue($this->mailQueuePdo->isEmpty() === false);

        $mailJob = $this->mailQueuePdo->dequeue();

        $this->assertTrue($this->mailQueuePdo->isEmpty() === true);

        $this->assertTrue(!empty($mailJob->getMessage()));

        $dequeuedMailMessage = MailMessage::fromArray(json_decode($mailJob->getMessage(), true));

        $this->assertEquals(FixtureHelper::getMailMessage(), $dequeuedMailMessage);

        $mailJob->markAsCompleted();

        $this->mailQueuePdo->ack($mailJob);

        $this->assertTrue($this->mailQueuePdo->dequeue() === null);

    }

    public function testPdoEnqueDequeueWithCypher()

    {