return false;
}
try {
+ $conn->multi( Redis::PIPELINE );
+ $conn->hSetNx( $this->getQueueTypesKey(), $type, 'enabled' );
$conn->hSet( $this->getReadyQueueKey(), $this->encQueueName( $type, $wiki ), time() );
+ $conn->exec();
return true;
} catch ( RedisException $e ) {
return "jobqueue:aggregator:h-ready-queues:v1"; // global
}
+ /**
+ * @return string
+ */
+ private function getQueueTypesKey() {
+ return "jobqueue:aggregator:h-queue-types:v1"; // global
+ }
+
/**
* @param string $type
* @param string $wiki