Sleep

Author: gurkov

src/AsyncQueue.php

@@ -5,6 +5,7 @@
 use Illuminate\Queue\DatabaseQueue;
 use Illuminate\Queue\Jobs\DatabaseJob;
 use Symfony\Component\Process\Process;
+use Carbon\Carbon;
 
 class AsyncQueue extends DatabaseQueue
 {
@@ -130,7 +131,7 @@ public function getJobFromId($id)
         if($job) {
 
 			return new DatabaseJob(
-				$this->container, $this, $job, $queue
+				$this->container, $this, $job, $job->queue
 			);
         }
 	}

src/Console/AsyncCommand.php

@@ -74,10 +74,10 @@ protected function processJob($connectionName, $id)
 		// we will "sleep" the worker for the specified number of seconds.
 		if ( ! is_null($job))
 		{
-            $sleep = $job->available_at - time();
+            $sleep = max($job->getDatabaseJob()->available_at - time(), 0);
             sleep($sleep);
 			return $this->worker->process(
-				$manager->getName($connectionName), $job, $maxTries, $delay
+				$manager->getName($connectionName), $job
 			);
 		}