Added delete from delay queue.

Author: limingxinleo

src/Driver/DriverInterface.php

@@ -26,6 +26,11 @@ public function push(JobInterface $job): bool;
      */
     public function delay(JobInterface $job, int $delay = 0): bool;
 
+    /**
+     * Delete a delay job to queue.
+     */
+    public function delete(JobInterface $job): bool;
+
     /**
      * Pop a job from queue.
      */

src/Driver/RedisDriver.php

@@ -80,6 +80,14 @@ public function delay(JobInterface $job, int $delay = 0): bool
         return $this->redis->zAdd($this->channel->getDelayed(), time() + $delay, $data) > 0;
     }
 
+    public function delete(JobInterface $job): bool
+    {
+        $message = new Message($job);
+        $data = $this->packer->pack($message);
+
+        return (bool) $this->redis->zRem($this->channel->getDelayed(), $data);
+    }
+
     public function pop(): array
     {
         $this->move($this->channel->getDelayed(), $this->channel->getWaiting());