Merge pull request #3 from abachmann/master

Laravel 5 support added

Author: matyunin

.gitignore

@@ -1,2 +1,3 @@
 .idea
-vendor
+vendor
+composer.lock

composer.json

@@ -8,9 +8,9 @@
     "videlalvaro/php-amqplib": "2.4.*"
   },
   "require-dev": {
-    "laravel/framework": "4.*",
+    "laravel/framework": ">=4.0.0",
     "squizlabs/php_codesniffer": "1.*",
-    "orchestra/testbench": "2.*",
+    "orchestra/testbench": "3.0.4",
     "phpunit/phpunit": "4.3.*"
   },
   "autoload": {

src/Connectors/AmqpConnector.php

@@ -18,7 +18,7 @@ class AmqpConnector implements ConnectorInterface
      *
      * @param  array $config
      *
-     * @return \Illuminate\Queue\QueueInterface
+     * @return \Illuminate\Queue\Queue
      */
     public function connect(array $config)
     {

src/Jobs/AMQPJob.php

@@ -4,7 +4,7 @@
 
 use Illuminate\Container\Container;
 use Illuminate\Queue\Jobs\Job;
-use Illuminate\Queue\QueueInterface;
+use Illuminate\Queue\Queue;
 use PhpAmqpLib\Channel\AMQPChannel;
 use PhpAmqpLib\Message\AMQPMessage;
 
@@ -106,12 +106,12 @@ public function release($delay = 0)
         $job = $body['job'];
         $data = $body['data'];
 
-        /** @var QueueInterface $queueInterface */
-        $queueInterface = $this->container['queue']->connection();
+        /** @var Queue $queue */
+        $queue = $this->container['queue']->connection();
         if ($delay > 0) {
-            $queueInterface->later($delay, $job, $data, $this->getQueue());
+            $queue->later($delay, $job, $data, $this->getQueue());
         } else {
-            $queueInterface->push($job, $data, $this->getQueue());
+            $queue->push($job, $data, $this->getQueue());
         }
     }
 

src/Queue/AMQPQueue.php

@@ -5,7 +5,6 @@
 use Forumhouse\LaravelAmqp\Exception\AMQPException;
 use Forumhouse\LaravelAmqp\Jobs\AMQPJob;
 use Illuminate\Queue\Queue;
-use Illuminate\Queue\QueueInterface;
 use PhpAmqpLib\Channel\AMQPChannel;
 use PhpAmqpLib\Connection\AMQPConnection;
 use PhpAmqpLib\Message\AMQPMessage;
@@ -15,7 +14,7 @@
  *
  * @package Forumhouse\LaravelAmqp\Queue
  */
-class AMQPQueue extends Queue implements QueueInterface
+class AMQPQueue extends Queue
 {
     const EXCHANGE_TYPE_DIRECT = 'direct';