- compatibility fix

martianoff · martianoff · commit 3a3c788d5d77 · 2016-09-06T15:24:08.000+07:00
diff --git a/src/Jobs/AMQPJob.php b/src/Jobs/AMQPJob.php
@@ -50,11 +50,10 @@ public function __construct($container, $queue, $channel, $amqpMessage)
      */
     public function fire()
     {
-        $payload = json_decode($this->amqpMessage->body, true);
-        if (is_null($payload))
+        if (is_null($this->payload()))
             $this->delete();
         else
-            $this->resolveAndFire($payload);
+            $this->fire();
     }
 
     /**

Original file line number	Diff line number	Diff line change
`@@ -50,11 +50,10 @@ public function __construct($container, $queue, $channel, $amqpMessage)`
`50`	`50`	`*/`
`51`	`51`	`public function fire()`
`52`	`52`	`{`
`53`		`- $payload = json_decode($this->amqpMessage->body, true);`
`54`		`- if (is_null($payload))`
	`53`	`+ if (is_null($this->payload()))`
`55`	`54`	`$this->delete();`
`56`	`55`	`else`
`57`		`- $this->resolveAndFire($payload);`
	`56`	`+ $this->fire();`
`58`	`57`	`}`
`59`	`58`
`60`	`59`	`/**`