fix delay queue

Author: walkor

src/Client.php

@@ -113,11 +113,17 @@ public function send($queue, $data, $delay = 0, $cb = null)
             $cb = function ($ret) use ($cb) {
                $cb((bool)$ret);
             };
+            if ($delay == 0) {
+                $this->_redisSend->lPush(static::QUEUE_WAITING . $queue, $package_str, $cb);
+            } else {
+                $this->_redisSend->zAdd(static::QUEUE_DELAYED, $now + $delay, $package_str, $cb);
+            }
+            return;
         }
         if ($delay == 0) {
-            $this->_redisSend->lPush(static::QUEUE_WAITING . $queue, $package_str, $cb);
+            $this->_redisSend->lPush(static::QUEUE_WAITING . $queue, $package_str);
         } else {
-            $this->_redisSend->zAdd(static::QUEUE_DELAYED, $now + $delay, $package_str, $cb);
+            $this->_redisSend->zAdd(static::QUEUE_DELAYED, $now + $delay, $package_str);
         }
     }