diff --git a/src/Illuminate/Queue/Console/FailedTableCommand.php b/src/Illuminate/Queue/Console/FailedTableCommand.php index 0b485ddc..6cbf8632 100644 --- a/src/Illuminate/Queue/Console/FailedTableCommand.php +++ b/src/Illuminate/Queue/Console/FailedTableCommand.php @@ -42,8 +42,8 @@ public function __construct(Filesystem $files) /** * Execute the console command. * - * @return void - */ + * @return int + */ public function fire() { $fullPath = $this->createBaseMigration(); @@ -51,6 +51,8 @@ public function fire() $this->files->put($fullPath, $this->files->get(__DIR__.'/stubs/failed_jobs.stub')); $this->info('Migration created successfully!'); + + return 0; } /** diff --git a/src/Illuminate/Queue/Console/FlushFailedCommand.php b/src/Illuminate/Queue/Console/FlushFailedCommand.php index 0ece99b5..91f6fba9 100644 --- a/src/Illuminate/Queue/Console/FlushFailedCommand.php +++ b/src/Illuminate/Queue/Console/FlushFailedCommand.php @@ -21,7 +21,6 @@ class FlushFailedCommand extends Command { /** * Execute the console command. * - * @return void */ public function fire() { diff --git a/src/Illuminate/Queue/Console/ForgetFailedCommand.php b/src/Illuminate/Queue/Console/ForgetFailedCommand.php index fef76f08..d2c1e7ae 100644 --- a/src/Illuminate/Queue/Console/ForgetFailedCommand.php +++ b/src/Illuminate/Queue/Console/ForgetFailedCommand.php @@ -22,8 +22,8 @@ class ForgetFailedCommand extends Command { /** * Execute the console command. * - * @return void - */ + * @return int + */ public function fire() { if ($this->laravel['queue.failer']->forget($this->argument('id'))) @@ -34,6 +34,8 @@ public function fire() { $this->error('No failed job matches the given ID.'); } + + return 0; } /** diff --git a/src/Illuminate/Queue/Console/ListFailedCommand.php b/src/Illuminate/Queue/Console/ListFailedCommand.php index 469015e7..328c97b9 100644 --- a/src/Illuminate/Queue/Console/ListFailedCommand.php +++ b/src/Illuminate/Queue/Console/ListFailedCommand.php @@ -21,8 +21,8 @@ class ListFailedCommand extends Command { /** * Execute the console command. * - * @return void - */ + * @return int + */ public function fire() { $rows = array(); @@ -34,7 +34,8 @@ public function fire() if (count($rows) == 0) { - return $this->info('No failed jobs!'); + $this->info('No failed jobs!'); + return 0; } $table = $this->getHelperSet()->get('table'); @@ -42,6 +43,8 @@ public function fire() $table->setHeaders(array('ID', 'Connection', 'Queue', 'Class', 'Failed At')) ->setRows($rows) ->render($this->output); + + return 0; } /** diff --git a/src/Illuminate/Queue/Console/RestartCommand.php b/src/Illuminate/Queue/Console/RestartCommand.php index de02cd7d..80313e09 100644 --- a/src/Illuminate/Queue/Console/RestartCommand.php +++ b/src/Illuminate/Queue/Console/RestartCommand.php @@ -21,13 +21,15 @@ class RestartCommand extends Command { /** * Execute the console command. * - * @return void - */ + * @return int + */ public function fire() { $this->laravel['cache']->forever('illuminate:queue:restart', time()); $this->info('Broadcasting queue restart signal.'); + + return 0; } } diff --git a/src/Illuminate/Queue/Console/RetryCommand.php b/src/Illuminate/Queue/Console/RetryCommand.php index 454b56d2..8f110201 100644 --- a/src/Illuminate/Queue/Console/RetryCommand.php +++ b/src/Illuminate/Queue/Console/RetryCommand.php @@ -22,8 +22,8 @@ class RetryCommand extends Command { /** * Execute the console command. * - * @return void - */ + * @return int + */ public function fire() { $failed = $this->laravel['queue.failer']->find($this->argument('id')); @@ -42,6 +42,8 @@ public function fire() { $this->error('No failed job matches the given ID.'); } + + return 0; } /** diff --git a/src/Illuminate/Queue/Console/SubscribeCommand.php b/src/Illuminate/Queue/Console/SubscribeCommand.php index 89c4209e..ce68fc3a 100755 --- a/src/Illuminate/Queue/Console/SubscribeCommand.php +++ b/src/Illuminate/Queue/Console/SubscribeCommand.php @@ -32,8 +32,8 @@ class SubscribeCommand extends Command { /** * Execute the console command. * - * @return void - * + * @return int + * * @throws \RuntimeException */ public function fire() @@ -48,6 +48,8 @@ public function fire() $iron->getIron()->updateQueue($this->argument('queue'), $this->getQueueOptions()); $this->line('Queue subscriber added: '.$this->argument('url').''); + + return 0; } /**