Merge pull request #8 from uafrica/delay-before-requeue

Add 100ms delay before requeue
uafrica · Dec 5, 2016 · d580eaa · d580eaa
2 parents e27019f + ead972f
commit d580eaa
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/DelayedJob/JobManager.php b/src/DelayedJob/JobManager.php
@@ -479,6 +479,9 @@ public function startConsuming()
 
                 $this->djLog(__('Will retry job {0}', $job->getId()));
 
+                // Sleep 100ms before requeuing the job... sometimes RabbitMQ is just too fast.
+                usleep(100 * 1000);
+
                 $this->requeueJob($job);
 
                 return;