traderinteractive / mongo-queue-php

     * @test

     * @covers ::send

     */

    public function send()

    {

        $payload = ['key1' => 0, 'key2' => true];

        $this->queue->send($payload, 34, 0.8);

        $this->assertSingleMessage(

            [

                'payload' => $payload,

                'earliestGet' => 34,

                'priority' => 0.8,

            ]

        );

    }

    /**

     * @test

     *

     * @return void

     */

    public function constructWithCollection()

    {

        $queue = new Queue($this->collection);

        $payload = ['key1' => 0, 'key2' => true];

        $queue->send($payload, 34, 0.8);

        $this->assertSingleMessage(

            [

                'payload' => $payload,

                'earliestGet' => 34,

                'priority' => 0.8,

            ]

        );

    }

    private function assertSingleMessage(array $expected)

    {