mirror of
https://github.com/predis/predis.git
synced 2026-10-08 21:06:44 +00:00
Daniele Alessandri
b553c6b9d0
This should not break existing code but allows users to retrieve more easily the current dispatcher loop instance without resorting to some tricks (like relying on the "use()" directive with closures).
127 lines
4.0 KiB
PHP
127 lines
4.0 KiB
PHP
<?php
|
|
|
|
/*
|
|
* This file is part of the Predis package.
|
|
*
|
|
* (c) Daniele Alessandri <suppakilla@gmail.com>
|
|
*
|
|
* For the full copyright and license information, please view the LICENSE
|
|
* file that was distributed with this source code.
|
|
*/
|
|
|
|
namespace Predis\PubSub;
|
|
|
|
use Predis\Client;
|
|
use PredisTestCase;
|
|
|
|
/**
|
|
* @group realm-pubsub
|
|
*/
|
|
class DispatcherLoopTest extends PredisTestCase
|
|
{
|
|
// ******************************************************************** //
|
|
// ---- INTEGRATION TESTS --------------------------------------------- //
|
|
// ******************************************************************** //
|
|
|
|
/**
|
|
* @group connected
|
|
* @requiresRedisVersion >= 2.0.0
|
|
*/
|
|
public function testDispatcherLoopAgainstRedisServer()
|
|
{
|
|
$parameters = array(
|
|
'host' => REDIS_SERVER_HOST,
|
|
'port' => REDIS_SERVER_PORT,
|
|
'database' => REDIS_SERVER_DBNUM,
|
|
// Prevents suite from hanging on broken test
|
|
'read_write_timeout' => 2,
|
|
);
|
|
|
|
$producer = new Client($parameters);
|
|
$producer->connect();
|
|
|
|
$consumer = new Client($parameters);
|
|
$consumer->connect();
|
|
|
|
$pubsub = new Consumer($consumer);
|
|
$dispatcher = new DispatcherLoop($pubsub);
|
|
|
|
$function01 = $this->getMock('stdClass', array('__invoke'));
|
|
$function01->expects($this->exactly(2))
|
|
->method('__invoke')
|
|
->with($this->logicalOr(
|
|
$this->equalTo('01:argument'),
|
|
$this->equalTo('01:quit')
|
|
), $dispatcher)
|
|
->will($this->returnCallback(function ($arg, $dispatcher) {
|
|
if ($arg === '01:quit') {
|
|
$dispatcher->stop();
|
|
}
|
|
}));
|
|
|
|
$function02 = $this->getMock('stdClass', array('__invoke'));
|
|
$function02->expects($this->once())
|
|
->method('__invoke')
|
|
->with('02:argument');
|
|
|
|
$function03 = $this->getMock('stdClass', array('__invoke'));
|
|
$function03->expects($this->never())
|
|
->method('__invoke');
|
|
|
|
$dispatcher->attachCallback('function:01', $function01);
|
|
$dispatcher->attachCallback('function:02', $function02);
|
|
$dispatcher->attachCallback('function:03', $function03);
|
|
|
|
$producer->publish('function:01', '01:argument');
|
|
$producer->publish('function:02', '02:argument');
|
|
$producer->publish('function:01', '01:quit');
|
|
|
|
$dispatcher->run();
|
|
|
|
$this->assertEquals('PONG', $consumer->ping());
|
|
}
|
|
|
|
/**
|
|
* @group connected
|
|
* @requiresRedisVersion >= 2.0.0
|
|
*/
|
|
public function testDispatcherLoopAgainstRedisServerWithPrefix()
|
|
{
|
|
$parameters = array(
|
|
'host' => REDIS_SERVER_HOST,
|
|
'port' => REDIS_SERVER_PORT,
|
|
'database' => REDIS_SERVER_DBNUM,
|
|
// Prevents suite from handing on broken test
|
|
'read_write_timeout' => 2,
|
|
);
|
|
|
|
$producerNonPfx = new Client($parameters);
|
|
$producerNonPfx->connect();
|
|
|
|
$producerPfx = new Client($parameters, array('prefix' => 'foobar'));
|
|
$producerPfx->connect();
|
|
|
|
$consumer = new Client($parameters, array('prefix' => 'foobar'));
|
|
|
|
$pubsub = new Consumer($consumer);
|
|
$dispatcher = new DispatcherLoop($pubsub);
|
|
|
|
$callback = $this->getMock('stdClass', array('__invoke'));
|
|
$callback->expects($this->exactly(1))
|
|
->method('__invoke')
|
|
->with($this->equalTo('arg:prefixed'), $dispatcher)
|
|
->will($this->returnCallback(function ($arg, $dispatcher) {
|
|
$dispatcher->stop();
|
|
}));
|
|
|
|
$dispatcher->attachCallback('callback', $callback);
|
|
|
|
$producerNonPfx->publish('callback', 'arg:non-prefixed');
|
|
$producerPfx->publish('callback', 'arg:prefixed');
|
|
|
|
$dispatcher->run();
|
|
|
|
$this->assertEquals('PONG', $consumer->ping());
|
|
}
|
|
}
|