diff --git a/composer.json b/composer.json index 2fafefa..a9aedd9 100644 --- a/composer.json +++ b/composer.json @@ -11,9 +11,9 @@ ], "require": { "php": ">=5.3.0", - "illuminate/support": "4.0.x", - "illuminate/queue": "4.0.x", - "illuminate/filesystem": "4.0.x" + "illuminate/support": "*", + "illuminate/queue": "*", + "illuminate/filesystem": "*" }, "require-dev": { "orchestra/testbench": "2.0.*", @@ -26,4 +26,4 @@ } }, "minimum-stability": "dev" -} \ No newline at end of file +} diff --git a/src/Mcpruitt/FileQueue/FileQueue.php b/src/Mcpruitt/FileQueue/FileQueue.php index b97e490..e99560e 100644 --- a/src/Mcpruitt/FileQueue/FileQueue.php +++ b/src/Mcpruitt/FileQueue/FileQueue.php @@ -258,4 +258,17 @@ protected function getInProcessQueueDirectory($queue = null, $create = false) { } return $path; } -} \ No newline at end of file + +/** + * Push a raw payload onto the queue. + * + * @param string $payload + * @param string $queue + * @param array $options + * @return mixed + */ +public function pushRaw($payload, $queue = null, array $options = array()) +{ + // +} +} diff --git a/src/Mcpruitt/FileQueue/Jobs/FileQueueJob.php b/src/Mcpruitt/FileQueue/Jobs/FileQueueJob.php index 5a23fdf..4ebea4f 100644 --- a/src/Mcpruitt/FileQueue/Jobs/FileQueueJob.php +++ b/src/Mcpruitt/FileQueue/Jobs/FileQueueJob.php @@ -80,6 +80,8 @@ public function fire() 'job' => $this->job_name, 'data' => (array) $this->job_data ); + if (isset($payload['data']['data'])) + $payload['data']['data'] = (array) $payload['data']['data']; $this->resolveAndFire($payload); } } catch (\Exception $e) { @@ -161,4 +163,9 @@ public function getDue() { return $this->due_date; } -} \ No newline at end of file + + public function getRawBody() + { + // + } +}