diff --git a/examples/PubSubContext.php b/examples/PubSubContext.php index 7d7fe72a..38b8a2fb 100644 --- a/examples/PubSubContext.php +++ b/examples/PubSubContext.php @@ -5,7 +5,7 @@ require_once '../lib/Predis.php'; $redis = new \Predis\Client('redis://127.0.0.1:6379/?read_write_timeout=-1', 'dev'); // Initialize a new pubsub context -$pubsub = new \Predis\PubSubContext($redis); +$pubsub = $redis->pubSubContext(); // Subscribe to your channels $pubsub->subscribe('control_channel'); diff --git a/lib/Predis.php b/lib/Predis.php index f489205c..d8045b3c 100644 --- a/lib/Predis.php +++ b/lib/Predis.php @@ -216,6 +216,10 @@ class Client { $multiExec = new MultiExecBlock($this); return $multiExecBlock !== null ? $multiExec->execute($multiExecBlock) : $multiExec; } + + public function pubSubContext() { + return new PubSubContext($this); + } } /* ------------------------------------------------------------------------- */