adding redis cluster support

This commit is contained in:
Daniel Ceballos 2010-05-28 04:26:37 +08:00 committed by Chris Boulton
parent 9ce7cfb370
commit be2ffa7d6c
2 changed files with 112 additions and 4 deletions

View file

@ -26,10 +26,17 @@ class Resque
*/
public static function setBackend($server)
{
list($host, $port) = explode(':', $server);
if(is_array($server)) {
require_once dirname(__FILE__) . '/Resque/Redis.php';
self::$redis = new Resque_Redis($host, $port);
require_once dirname(__FILE__) . '/Resque/RedisCluster.php';
self::$redis = new Resque_RedisCluster($server);
}else{
list($host, $port) = explode(':', $server);
require_once dirname(__FILE__) . '/Resque/Redis.php';
self::$redis = new Resque_Redis($host, $port);
}
}
/**
@ -125,4 +132,4 @@ class Resque
}
return $queues;
}
}
}