Skip to content
Merged
Changes from 2 commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
6 changes: 6 additions & 0 deletions src/MongodbQueueServiceProvider.php
Original file line number Diff line number Diff line change
Expand Up @@ -4,6 +4,7 @@

use Illuminate\Queue\QueueServiceProvider;
use Jenssegers\Mongodb\Queue\Failed\MongoFailedJobProvider;
use Illuminate\Queue\Failed\NullFailedJobProvider;

class MongodbQueueServiceProvider extends QueueServiceProvider
{
Expand All @@ -12,6 +13,11 @@ class MongodbQueueServiceProvider extends QueueServiceProvider
*/
protected function registerFailedJobServices()
{
if (array_key_exists('driver', $config) &&
(is_null($config['driver']) || $config['driver'] === 'null')) {
return new NullFailedJobProvider;
}

// Add compatible queue failer if mongodb is configured.
if ($this->app['db']->connection(config('queue.failed.database'))->getDriverName() == 'mongodb') {
$this->app->singleton('queue.failer', function ($app) {
Expand Down