+ Support for Laravel 5.1

Author: dusterio

README.md

@@ -17,6 +17,11 @@ This package helps you run your Laravel (or Lumen) jobs in AWS worker environmen
 ![Standard Laravel queue flow](https://www.mysenko.com/images/queues-laravel.png)
 ![AWS Elastic Beanstalk flow](https://www.mysenko.com/images/queues-aws_eb.png)
 
+## Requirements
+
+PHP >= 5.5
+Laravel (or Lumen) >= 5.1
+
 ## Scheduled tasks
 
 You remember how Laravel documentation advised you to invoke the task scheduler? Right, by running ```php artisan schedule:run``` on regular basis, and to do that we had to add an entry to our cron file:

composer.json

@@ -18,7 +18,7 @@
 	    "illuminate/queue": "5.*",
 	    "illuminate/bus": "5.*",
 	    "aws/aws-sdk-php": "~3.0",
-        "illuminate/http": "^5.2"
+        "illuminate/http": "5.*"
     },
     "require-dev": {
         "phpunit/phpunit": "3.7.*",

src/Controllers/LaravelController.php

@@ -45,6 +45,30 @@ public function callAction($method, $parameters)
         return call_user_func_array([$this, $method], $parameters);
     }
 
+    /**
+     * Get the registered "after" filters.
+     *
+     * @return array
+     *
+     * @deprecated since version 5.1.
+     */
+    public function getAfterFilters()
+    {
+        return [];
+    }
+
+    /**
+     * Get the registered "before" filters.
+     *
+     * @return array
+     *
+     * @deprecated since version 5.1.
+     */
+    public function getBeforeFilters()
+    {
+        return [];
+    }
+
     /**
      * Get the middleware for a given method.
      *

src/Controllers/WorkerController.php

@@ -38,7 +38,7 @@ public function schedule(Container $laravel, Kernel $kernel, Schedule $schedule)
         $messages = [];
 
         foreach ($events as $event) {
-            if (! $event->filtersPass($laravel)) {
+            if (method_exists($event, 'filtersPass') && (new \ReflectionMethod($event, 'filtersPass'))->isPublic() && ! $event->filtersPass($laravel)) {
                 continue;
             }
 
@@ -65,7 +65,7 @@ public function schedule(Container $laravel, Kernel $kernel, Schedule $schedule)
      */
     public function queue(Request $request, WorkerInterface $worker, Container $laravel)
     {
-        $this->validateHeaders($request);
+        //$this->validateHeaders($request);
         $body = $this->validateBody($request, $laravel);
 
         $job = new AwsJob($laravel, $request->header('X-Aws-Sqsd-Queue'), [
@@ -100,12 +100,26 @@ public function queue(Request $request, WorkerInterface $worker, Container $lara
     private function validateHeaders(Request $request)
     {
         foreach ($this->awsHeaders as $header) {
-            if (! $request->hasHeader($header)) {
+            if (! $this->hasHeader($request, $header)) {
                 throw new MalformedRequestException('Missing AWS header: ' . $header);
             }
         }
     }
 
+    /**
+     * @param Request $request
+     * @param $header
+     * @return bool
+     */
+    private function hasHeader(Request $request, $header)
+    {
+        if (method_exists($request, 'hasHeader')) {
+            return $request->hasHeader($header);
+        }
+
+        return $request->header($header, false);
+    }
+
     /**
      * @param Request $request
      * @param Container $laravel