dispatch to the queue defined

ElegantEngineeringTech · Jan 12, 2025 · 80edf13 · 80edf13
1 parent f27376e
commit 80edf13
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 4 deletions.
diff --git a/src/Definitions/MediaConversionDefinition.php b/src/Definitions/MediaConversionDefinition.php
@@ -66,10 +66,12 @@ public function shouldExecute(Media $media, ?MediaConversion $parent): bool
 
     public function dispatch(Media $media, ?MediaConversion $parent): PendingDispatch
     {
-        return dispatch(new MediaConversionJob(
+        $job = new MediaConversionJob(
             media: $media,
             conversion: $parent ? "{$parent->conversion_name}.{$this->name}" : $this->name
-        ));
+        );
+
+        return dispatch($job)->onQueue($this->queue ?? $job->queue);
     }
 
     public function execute(Media $media, ?MediaConversion $parent): ?MediaConversion

diff --git a/src/Models/Media.php b/src/Models/Media.php
@@ -261,10 +261,12 @@ public function dispatchConversion(
 
         if ($definition = $this->getConversionDefinition($conversion)) {
 
-            return dispatch(new MediaConversionJob(
+            $job = new MediaConversionJob(
                 media: $this,
                 conversion: $conversion
-            ));
+            );
+
+            return dispatch($job)->onQueue($definition->queue ?? $job->queue);
 
         }