Merge pull request #6 from koolay/lumen

支持Lumen5.3

src/Connectors/MnsConnector.php

@@ -15,7 +15,6 @@
 namespace LaravelMns\Connectors;
 
 use AliyunMNS\Client as MnsClient;
-use Config;
 use Illuminate\Queue\Connectors\ConnectorInterface;
 use LaravelMns\MnsAdapter;
 use LaravelMns\MnsQueue;
@@ -36,7 +35,7 @@ class MnsConnector implements ConnectorInterface
      */
     public function connect(array $config)
     {
-        $config = Config::get('queue.connections.mns');
+        $config = config('queue.connections.mns');
 
         return new MnsQueue(
             new MnsAdapter(

src/Jobs/MnsJob.php

@@ -63,17 +63,16 @@ public function __construct(
 
     /**
      * Fire the job.
+     *
+     * @return void
      */
     public function fire()
     {
-        $body = json_decode($this->getRawBody(), true);
-        if (!is_array($body)) {
-            throw new \InvalidArgumentException(
-                "Seems it's not a Laravel enqueued job. \r\n
-                [$body]"
-            );
+        if (method_exists($this, 'resolveAndFire')) {
+            $this->resolveAndFire(json_decode($this->getRawBody(), true));
+            return;
         }
-        $this->resolveAndFire($body);
+        parent::fire();
     }
 
     /**
@@ -106,7 +105,7 @@ public function release($delay = 0)
         // 默认情况下 Laravel 将以 delay 0 来更改可见性，其预期的是使用队列服务默认的
         // 下次可消费时间，但 Aliyun MNS PHP SDK 的接口要求这个值必须大于 0，
         // 指从现在起，多久后消息变为可消费。
-        $delay = 0 !== $delay
+        $delay = $delay > 0
             ? $delay
             : $this->fromNowToNextVisibleTime($this->job->getNextVisibleTime());
         parent::release($delay);

src/MnsQueue.php

@@ -125,7 +125,7 @@ public function pop($queue = null)
             }
         }
 
-        return;
+        return null;
     }
 
     /**
@@ -153,4 +153,15 @@ public function createJobsUsing(callable $callback)
 
         return $this;
     }
+
+    /**
+     * Get the size of the queue.
+     *
+     * @param  string $queue
+     * @return int
+     */
+    public function size($queue = null)
+    {
+        throw new NotImplementedException('size方法没有实现');
+    }
 }

src/NotImplementedException.php

@@ -0,0 +1,9 @@
+<?php
+
+namespace LaravelMns;
+
+
+class NotImplementedException extends \Exception
+{
+
+}