diff --git a/lib/MongoQueue.php b/lib/MongoQueue.php index 82e2f63..e408aed 100644 --- a/lib/MongoQueue.php +++ b/lib/MongoQueue.php @@ -42,7 +42,7 @@ public static function push($className, $methodName, $parameters, $when, $batch { $job = $job['value']; - if (!isset($job['when'])) + if (!isset($job['when']) || $job['when'] > $when) { $job['when'] = $when; $collection->save($job);