parent::__construct( $params );
$params['redisConfig']['serializer'] = 'none'; // make it easy to use Lua
$this->server = $params['redisServer'];
- $this->compression = isset( $params['compression'] ) ? $params['compression'] : 'none';
+ $this->compression = $params['compression'] ?? 'none';
$this->redisPool = RedisConnectionPool::singleton( $params['redisConfig'] );
if ( empty( $params['daemonized'] ) ) {
throw new InvalidArgumentException(
* @return string JSON
*/
private function encodeQueueName() {
- return json_encode( [ $this->type, $this->wiki ] );
+ return json_encode( [ $this->type, $this->domain ] );
}
/**
*/
private function getQueueKey( $prop, $type = null ) {
$type = is_string( $type ) ? $type : $this->type;
- list( $db, $prefix ) = wfSplitWikiID( $this->wiki );
- $keyspace = $prefix ? "$db-$prefix" : $db;
+
+ // Use wiki ID for b/c
+ $keyspace = WikiMap::getWikiIdFromDomain( $this->domain );
$parts = [ $keyspace, 'jobqueue', $type, $prop ];