修正 并 添加助手函数

src/common.php

@@ -14,4 +14,23 @@
     "think\\queue\\command\\Restart",
     "think\\queue\\command\\Listen",
     "think\\queue\\command\\Subscribe"
-]);
+]);
+
+if (!function_exists('queue')) {
+
+    /**
+     * 添加到队列
+     * @param        $job
+     * @param string $data
+     * @param int    $delay
+     * @param null   $queue
+     */
+    function queue($job, $data = '', $delay = 0, $queue = null)
+    {
+        if ($delay > 0) {
+            \think\Queue::later($delay, $job, $data, $queue);
+        } else {
+            \think\Queue::push($job, $data, $queue);
+        }
+    }
+}

src/queue/Queueable.php

@@ -25,7 +25,7 @@ trait Queueable
      * @param $queue
      * @return $this
      */
-    public function onQueue($queue)
+    public function queue($queue)
     {
         $this->queue = $queue;
 

src/queue/Worker.php

@@ -13,6 +13,7 @@
 
 use Exception;
 use think\Hook;
+use think\Queue;
 
 class Worker
 {