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 fd7ef90..60c6683 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; @@ -121,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, [self::PARAMETER_NAME_MAIL_QUEUE_ENTRY_ID => $entry->getId()]); + $this->backgroundQueueService->publish($this->backgroundQueueCallbackName, [$entry->getId()], null, null, false, null, $backgroundQueuePriority); return $entry; }