如何在laravel 5中为失败的作业插入覆盖数据库连接

我正在尝试开发一个多租户多数据库应用程序，这基本上意味着每个租户都有自己的数据库、用户、资源等。

当然，当收到请求时，Laravel需要知道要使用哪个数据库连接，所以我编写了一个中间件，它基本上解析请求中的JWT，查找租户id或用户名，然后简单地连接到租户的数据库。

但现在我正在处理队列，我正试图超越laravel 5的默认行为，它连接到主数据库并插入失败的作业记录。

当我深入查看供应商文件时，我发现了一个FailedJobProvider接口：

<?php
namespace Illuminate'Queue'Failed;
interface FailedJobProviderInterface
{
    /**
     * Log a failed job into storage.
     *
     * @param  string  $connection
     * @param  string  $queue
     * @param  string  $payload
     * @return void
     */
    public function log($connection, $queue, $payload);
    /**
     * Get a list of all of the failed jobs.
     *
     * @return array
     */
    public function all();
    /**
     * Get a single failed job.
     *
     * @param  mixed  $id
     * @return array
     */
    public function find($id);
    /**
     * Delete a single failed job from storage.
     *
     * @param  mixed  $id
     * @return bool
     */
    public function forget($id);
    /**
     * Flush all of the failed jobs from storage.
     *
     * @return void
     */
    public function flush();
}

以及实现该接口的DatabaseFailedJobProvider类：

<?php
namespace Illuminate'Queue'Failed;
use Carbon'Carbon;
use Illuminate'Database'ConnectionResolverInterface;
class DatabaseFailedJobProvider implements FailedJobProviderInterface
{
    /**
     * The connection resolver implementation.
     *
     * @var 'Illuminate'Database'ConnectionResolverInterface
     */
    protected $resolver;
    /**
     * The database connection name.
     *
     * @var string
     */
    protected $database;
    /**
     * The database table.
     *
     * @var string
     */
    protected $table;
    /**
     * Create a new database failed job provider.
     *
     * @param  'Illuminate'Database'ConnectionResolverInterface  $resolver
     * @param  string  $database
     * @param  string  $table
     * @return void
     */
    public function __construct(ConnectionResolverInterface $resolver, $database, $table)
    {
        $this->table = $table;
        $this->resolver = $resolver;
        $this->database = $database;
    }
    /**
     * Log a failed job into storage.
     *
     * @param  string  $connection
     * @param  string  $queue
     * @param  string  $payload
     * @return void
     */
    public function log($connection, $queue, $payload)
    {
        $failed_at = Carbon::now();
        $this->getTable()->insert(compact('connection', 'queue', 'payload', 'failed_at'));
    }
    /**
     * Get a list of all of the failed jobs.
     *
     * @return array
     */
    public function all()
    {
        return $this->getTable()->orderBy('id', 'desc')->get();
    }
    /**
     * Get a single failed job.
     *
     * @param  mixed  $id
     * @return array
     */
    public function find($id)
    {
        return $this->getTable()->find($id);
    }
    /**
     * Delete a single failed job from storage.
     *
     * @param  mixed  $id
     * @return bool
     */
    public function forget($id)
    {
        return $this->getTable()->where('id', $id)->delete() > 0;
    }
    /**
     * Flush all of the failed jobs from storage.
     *
     * @return void
     */
    public function flush()
    {
        $this->getTable()->delete();
    }
    /**
     * Get a new query builder instance for the table.
     *
     * @return 'Illuminate'Database'Query'Builder
     */
    protected function getTable()
    {
        return $this->resolver->connection($this->database)->table($this->table);
    }
}

所以我想，如果我编写自己的提供者，或者可以超越这个提供者，我就可以在插入失败的作业之前告诉laravel要连接到哪个数据库。但我对SOLID或OOP不太熟悉，在这种情况下我会感到困惑。

如何编写我自己的提供者或超越这个提供者来在旅途中更改数据库连接？