From 414b7286de82ed17d39b729938ddad9fb3231360 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Viktor=20Ma=C5=A1=C3=AD=C4=8Dek?= Date: Thu, 11 Aug 2022 14:19:34 +0200 Subject: [PATCH 1/2] Fix publish Background Queue parameters Cannot unpack array with string keys --- src/Service/QueueService.php | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/src/Service/QueueService.php b/src/Service/QueueService.php index fd7ef90..9317b7f 100644 --- a/src/Service/QueueService.php +++ b/src/Service/QueueService.php @@ -16,8 +16,6 @@ class QueueService { const MUTEX_TIME_FORMAT = DATE_W3C; - const PARAMETER_NAME_MAIL_QUEUE_ENTRY_ID = 'mailQueueEntry_id'; - /** @var string */ protected $queueEntryClass; @@ -126,7 +124,7 @@ public function enqueue(\Nette\Mail\Message $message, $custom = []) { $this->em->persist($entry); $this->em->flush($entry); - $this->backgroundQueueService->publish($this->backgroundQueueCallbackName, [self::PARAMETER_NAME_MAIL_QUEUE_ENTRY_ID => $entry->getId()]); + $this->backgroundQueueService->publish($this->backgroundQueueCallbackName, [$entry->getId()]); return $entry; } From 72a62421ca3c413477ad3c4e7175796e8ac63116 Mon Sep 17 00:00:00 2001 From: Viktor Masicek Date: Tue, 4 Jun 2024 15:38:34 +0200 Subject: [PATCH 2/2] Enable set priority for BackgroundQueue job --- composer.json | 2 +- src/Service/QueueService.php | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/composer.json b/composer.json index 95a652e..de7d184 100644 --- a/composer.json +++ b/composer.json @@ -15,7 +15,7 @@ "nette/mail": "~3.0", "nette/di": "^2.3 || ~3.0", "tracy/tracy": "^2.3", - "adt/background-queue": "^4.2" + "adt/background-queue": "^4.22" }, "autoload": { "psr-4": { diff --git a/src/Service/QueueService.php b/src/Service/QueueService.php index 9317b7f..60c6683 100644 --- a/src/Service/QueueService.php +++ b/src/Service/QueueService.php @@ -119,12 +119,12 @@ protected function createQueueEntry(\Nette\Mail\Message $message, $custom = []) * @param array|callable $custom * @return Entity\AbstractMailQueueEntry */ - public function enqueue(\Nette\Mail\Message $message, $custom = []) { + public function enqueue(\Nette\Mail\Message $message, $custom = [], ?int $backgroundQueuePriority = null) { $entry = $this->createQueueEntry($message, $custom); $this->em->persist($entry); $this->em->flush($entry); - $this->backgroundQueueService->publish($this->backgroundQueueCallbackName, [$entry->getId()]); + $this->backgroundQueueService->publish($this->backgroundQueueCallbackName, [$entry->getId()], null, null, false, null, $backgroundQueuePriority); return $entry; }