Fix default timestamp

ilzrv · Dec 26, 2020 · 7cecba9 · 7cecba9
1 parent 2aab87d
commit 7cecba9
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/src/Queue.php b/src/Queue.php
@@ -36,10 +36,16 @@ public function __construct(string $name, QueueOpts $opts = null)
      */
     public function add(string $name, array $data, JobOpts $opts = null)
     {
+        $timestamp = (int) round(microtime(true) * 1000);
+
         $opts = $opts ?: new JobOpts([
-            'timestamp' => (int) round(microtime(true) * 1000),
+            'timestamp' => $timestamp,
         ]);
 
+        if (!$opts->timestamp) {
+            $opts->timestamp = $timestamp;
+        }
+
         $prefix = sprintf('%s:%s:', $this->opts->prefix, $this->name);
 
         return $this->client()->add(