if (!
$address) { throw new InvalidArgumentException(sprintf('Failed to retrieve master information from sentinel "%s".',
$sentinelMaster), previous:
$redisException ?? null
);
} } return self::
initializeRedis($redis ?? (\
extension_loaded('redis'
) ?
new \
Redis() :
new Relay()),
$host,
$port,
$auth,
$options);
};
} if (!
$options['lazy'
]) { $this->
getRedis();
} foreach (['stream', 'group', 'consumer'
] as $key) { if ('' ===
$options[$key]) { throw new InvalidArgumentException(sprintf('"%s" should be configured, got an empty string.',
$key));
} } $this->stream =
$options['stream'
];
$this->group =
$options['group'
];
$this->consumer =
$options['consumer'
];