- skip bad payload jobs

Author: martianoff

src/Jobs/AMQPJob.php

@@ -50,17 +50,11 @@ public function __construct($container, $queue, $channel, $amqpMessage)
      */
     public function fire()
     {
-        $this->resolveAndFire(json_decode($this->amqpMessage->body, true));
-    }
-
-    /**
-     * Get the raw body string for the job.
-     *
-     * @return string
-     */
-    public function getRawBody()
-    {
-        return $this->amqpMessage->body;
+        $payload = json_decode($this->amqpMessage->body, true);
+        if (is_null($payload))
+            $this->delete();
+        else
+            $this->resolveAndFire($payload);
     }
 
     /**
@@ -75,13 +69,13 @@ public function delete()
     }
 
     /**
-     * Get queue name
+     * Get the raw body string for the job.
      *
      * @return string
      */
-    public function getQueue()
+    public function getRawBody()
     {
-        return $this->queue;
+        return $this->amqpMessage->body;
     }
 
     /**
@@ -127,6 +121,16 @@ public function attempts()
         return isset($body['data']['attempts']) ? $body['data']['attempts'] : 0;
     }
 
+    /**
+     * Get queue name
+     *
+     * @return string
+     */
+    public function getQueue()
+    {
+        return $this->queue;
+    }
+
     /**
      * Get the job identifier.
      *