Method testCanShareConnection

php/tests/QueueTest.php:361–389

()

    }

    public function testCanShareConnection(): void
    {
        $connection = new RedisConnection([
            'host' => getenv('REDIS_HOST') ?: 'localhost',
            'port' => (int)(getenv('REDIS_PORT') ?: 6379),
        ]);

        $queue1 = new Queue('shared-conn-queue-1', ['connection' => $connection]);
        $queue2 = new Queue('shared-conn-queue-2', ['connection' => $connection]);

        $job1 = $queue1->add('job-1', ['queue' => 1]);
        $job2 = $queue2->add('job-2', ['queue' => 2]);

        $this->assertNotNull($job1->id);
        $this->assertNotNull($job2->id);

        $queue1->obliterate(['force' => true]);
        $queue2->obliterate(['force' => true]);

        // Queues don't own the connection, so they shouldn't close it
        $queue1->close();
        $queue2->close();

        // Connection should still be usable
        $result = $connection->getClient()->ping();
        $this->assertNotNull($result);

        $connection->close();
    }

    public function testGetJobsByMultipleTypes(): void
    {