Why laravel dispatcer dispatch() function not creating jobs in jobs table of particular database?

Question

I have multiple databases and switching database as per some conditions before dispatching jobs. For eg:

if(condition A){
  DB::setDefaultConnection('A');
} else {
  DB::setDefaultConnection('B');
}
dispatch(new CreateNewUser($user))

And the db connection is changed as per the condition. As I query something like User::find($id) before dispatching the job which returns data as per the connected database. But the problem is, the dispatch() create a jobs record in jobs table of that database which was connected at first. When the db connection changed to another, still the first database's jobs table is populated. How is this happening?

JoeGalind · Accepted Answer · 2022-06-26 20:11:08Z

0

Based on the comment, do the following, purge and reconnect after your change:

DB::purge('mysql'); 
//Do whatever you need to do to setup your connection
DB::setDefaultConnection('B');
DB::reconnect('mysql');

The job you are dispatching runs async. That DB change you are performing is not performed inside the Job. You should send the connection name as a parameter to the Job:

dispatch(new CreateNewUser($user, $connName))

and on the Job initialization, do:

    protected $connName;

    public function __construct($user, $connName)
    {
        $this->connName = $connName;
    }

    public function handle()
    {
        DB::setDefaultConnection($this->connName);
        ....
    }

edited Jun 26, 2022 at 20:11

answered Jun 26, 2022 at 16:50

JoeGalind

3,8342 gold badges33 silver badges36 bronze badges

Sign up to request clarification or add additional context in comments.

2 Comments

amit Over a year ago

But I want to store the jobs to their particular database. That's why I'm changing default db-connection before dispatching jobs.

JoeGalind Over a year ago

In that case: DB::purge('mysql'); Config::set('database.connections.mysql.database', 'A'); DB::reconnect('mysql');

Collectives™ on Stack Overflow

Why laravel dispatcer dispatch() function not creating jobs in jobs table of particular database?

1 Answer 1

2 Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

2 Comments

Your Answer

Sign up or log in

Post as a guest

Related