| Server IP : 66.29.137.217 / Your IP : 18.220.167.202 Web Server : LiteSpeed System : Linux premium294.web-hosting.com 4.18.0-513.11.1.lve.el8.x86_64 #1 SMP Thu Jan 18 16:21:02 UTC 2024 x86_64 User : gltevjme ( 1095) PHP Version : 7.0.33 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : ON | Sudo : OFF | Pkexec : OFF Directory : /home/./gltevjme/bofirm.gltechlimited.com/vendor/predis/predis/src/PubSub/ |
Upload File : |
<?php
/*
* This file is part of the Predis package.
*
* (c) 2009-2020 Daniele Alessandri
* (c) 2021-2023 Till Krüss
*
* For the full copyright and license information, please view the LICENSE
* file that was distributed with this source code.
*/
namespace Predis\PubSub;
use Predis\NotSupportedException;
/**
* Relay PUB/SUB consumer.
*/
class RelayConsumer extends Consumer
{
/**
* Subscribes to the specified channels.
*
* @param string ...$channel One or more channel names.
* @param callable $callback The message callback.
*/
public function subscribe($channel) // @phpstan-ignore-line
{
$channels = func_get_args();
$callback = array_pop($channels);
$this->statusFlags |= self::STATUS_SUBSCRIBED;
$command = $this->client->createCommand('subscribe', [
$channels,
function ($relay, $channel, $message) use ($callback) {
$callback((object) [
'kind' => is_null($message) ? self::SUBSCRIBE : self::MESSAGE,
'channel' => $channel,
'payload' => $message,
], $relay);
},
]);
$this->client->getConnection()->executeCommand($command);
$this->invalidate();
}
/**
* Subscribes to the specified channels using a pattern.
*
* @param string ...$pattern One or more channel name patterns.
* @param callable $callback The message callback.
*/
public function psubscribe(...$pattern) // @phpstan-ignore-line
{
$patterns = func_get_args();
$callback = array_pop($patterns);
$this->statusFlags |= self::STATUS_PSUBSCRIBED;
$command = $this->client->createCommand('psubscribe', [
$patterns,
function ($relay, $pattern, $channel, $message) use ($callback) {
$callback((object) [
'kind' => is_null($message) ? self::PSUBSCRIBE : self::PMESSAGE,
'pattern' => $pattern,
'channel' => $channel,
'payload' => $message,
], $relay);
},
]);
$this->client->getConnection()->executeCommand($command);
$this->invalidate();
}
/**
* {@inheritDoc}
*/
protected function genericSubscribeInit($subscribeAction)
{
if (isset($this->options[$subscribeAction])) {
throw new NotSupportedException('Relay does not support Pub/Sub constructor options.');
}
}
/**
* {@inheritDoc}
*/
public function ping($payload = null)
{
throw new NotSupportedException('Relay does not support PING in Pub/Sub.');
}
/**
* {@inheritDoc}
*/
public function stop($drop = false)
{
return false;
}
/**
* {@inheritDoc}
*/
public function __destruct()
{
// NOOP
}
}