Merge pull request #12 from AppsDevTeam/bq-priorities

Enable set priority for BackgroundQueue job

Author: thorewi

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": {

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;
 	}