Skip to content
Snippets Groups Projects
Unverified Commit 6f0eb67b authored by Stefan Auditor's avatar Stefan Auditor Committed by Stefan Auditor
Browse files

Issue #3274237 by sanduhrs: [META] Porting localization server module to Drupal 9: Rename queues

parent 9ffda660
No related branches found
No related tags found
No related merge requests found
...@@ -13,7 +13,7 @@ use Drupal\l10n_server\Entity\L10nServerRelease; ...@@ -13,7 +13,7 @@ use Drupal\l10n_server\Entity\L10nServerRelease;
*/ */
function l10n_packager_cron(): void { function l10n_packager_cron(): void {
// Queue releases to be parsed. // Queue releases to be parsed.
$queue = \Drupal::queue('l10n_packager_queue'); $queue = \Drupal::queue('l10n_server_packager');
$storage = \Drupal::entityTypeManager() $storage = \Drupal::entityTypeManager()
->getStorage('l10n_packager_release'); ->getStorage('l10n_packager_release');
$ids = $storage->getIdsToQueue(); $ids = $storage->getIdsToQueue();
......
...@@ -7,12 +7,11 @@ use Drupal\Core\Queue\QueueWorkerBase; ...@@ -7,12 +7,11 @@ use Drupal\Core\Queue\QueueWorkerBase;
use Drupal\l10n_server\Entity\L10nServerReleaseInterface; use Drupal\l10n_server\Entity\L10nServerReleaseInterface;
/** /**
* Defines 'l10n_packager_queue' queue worker. * Defines 'l10n_server_packager' queue worker.
* *
* @QueueWorker( * @QueueWorker(
* id = "l10n_packager_queue", * id = "l10n_server_packager",
* title = @Translation("Package releases"), * title = @Translation("Package releases"),
* cron = {"time" = 60}
* ) * )
*/ */
class PackagerQueue extends QueueWorkerBase { class PackagerQueue extends QueueWorkerBase {
......
...@@ -14,7 +14,7 @@ use Drupal\views\Views; ...@@ -14,7 +14,7 @@ use Drupal\views\Views;
*/ */
function l10n_server_cron(): void { function l10n_server_cron(): void {
// Queue releases to be parsed. // Queue releases to be parsed.
$queue = \Drupal::queue('l10n_server_parser_queue'); $queue = \Drupal::queue('l10n_server_parser');
$storage = \Drupal::entityTypeManager() $storage = \Drupal::entityTypeManager()
->getStorage('l10n_server_release'); ->getStorage('l10n_server_release');
$ids = $storage->getIdsToQueue(); $ids = $storage->getIdsToQueue();
......
...@@ -191,7 +191,7 @@ class L10nServerCommands extends DrushCommands { ...@@ -191,7 +191,7 @@ class L10nServerCommands extends DrushCommands {
} }
// Queue releases to be parsed. // Queue releases to be parsed.
$queue = $this->queueFactory->get('l10n_server_parser_queue'); $queue = $this->queueFactory->get('l10n_server_parser');
$storage = $this $storage = $this
->entityTypeManager ->entityTypeManager
->getStorage('l10n_server_release'); ->getStorage('l10n_server_release');
......
...@@ -64,7 +64,7 @@ class L10nServerRelease extends ContentEntityBase implements L10nServerReleaseIn ...@@ -64,7 +64,7 @@ class L10nServerRelease extends ContentEntityBase implements L10nServerReleaseIn
} }
// Queue release to be parsed. // Queue release to be parsed.
$queue = \Drupal::queue('l10n_server_parser_queue'); $queue = \Drupal::queue('l10n_server_parser');
if ($queue->createItem($this)) { if ($queue->createItem($this)) {
// Add timestamp to avoid queueing item more than once. // Add timestamp to avoid queueing item more than once.
$this->setQueuedTime(\Drupal::time()->getRequestTime()); $this->setQueuedTime(\Drupal::time()->getRequestTime());
......
...@@ -8,12 +8,11 @@ use Drupal\l10n_server\Entity\L10nServerRelease; ...@@ -8,12 +8,11 @@ use Drupal\l10n_server\Entity\L10nServerRelease;
use Drupal\l10n_server\Entity\L10nServerReleaseInterface; use Drupal\l10n_server\Entity\L10nServerReleaseInterface;
/** /**
* Defines 'l10n_server_parser_queue' queue worker. * Defines 'l10n_server_parser' queue worker.
* *
* @QueueWorker( * @QueueWorker(
* id = "l10n_server_parser_queue", * id = "l10n_server_parser",
* title = @Translation("Parse releases"), * title = @Translation("Parse releases"),
* cron = {"time" = 60}
* ) * )
*/ */
class ParserQueue extends QueueWorkerBase { class ParserQueue extends QueueWorkerBase {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment