* This tracks all queue types in one simple location that
can be inspected without using MediaWiki.
Change-Id: I197664b9aa620b29f1400e5a60c55a301348120d
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