1

app/Module/DelayQueue/Redis.php

@@ -32,7 +32,8 @@ class Redis
         if ($a->exists($key)) {
             return 0;
         }
-        $a->setex($key, $delay, 1);
+        $delay= max(2, $delay);
+        $a->setex($key, max(1,$delay-1), 1);
 
         $q            = new Queue();
         $q->create_ts = time();