26 lines
739 B
PHP
26 lines
739 B
PHP
<?php
|
|
|
|
namespace BeyondCode\LaravelWebSockets\Queue;
|
|
|
|
use BeyondCode\LaravelWebSockets\Contracts\ChannelManager;
|
|
use Illuminate\Queue\RedisQueue;
|
|
|
|
class AsyncRedisQueue extends RedisQueue
|
|
{
|
|
/**
|
|
* Get the connection for the queue.
|
|
*
|
|
* @return \BeyondCode\LaravelWebSockets\Contracts\ChannelManager|\Illuminate\Redis\Connections\Connection
|
|
*/
|
|
public function getConnection()
|
|
{
|
|
$channelManager = $this->container->bound(ChannelManager::class)
|
|
? $this->container->make(ChannelManager::class)
|
|
: null;
|
|
|
|
return $channelManager && method_exists($channelManager, 'getRedisClient')
|
|
? $channelManager->getRedisClient()
|
|
: parent::getConnection();
|
|
}
|
|
}
|