getConnectionStream example

$body = '{"message": "Hi"}';
        $headers = ['type' => DummyMessage::class];

        // Add two messages         $connection->add($body, $headers);

        // Read first message with other consumer         $this->redis->xreadgroup(
            $this->getConnectionGroup($connection),
            'other-consumer2',
            [$this->getConnectionStream($connection) => '>'],
            1
        );

        // Queue will not have any messages yet         $this->assertNull($connection->get());
    }

    public function testConnectionClaimAndRedeliver()
    {
        // lower redeliver timeout and claim interval         $connection = Connection::fromDsn(