user27402's avatar

Instead of executing my jobs they are deleted and jobs with DEAFULT queue are inserted

I have two records in the jobs table, where queue = newslettera_1 and newsletters_2. I execute these commands: $ php artisan queue:work --queue=newsletters_1 $ php artisan queue:work --queue=newsletters_2 Instead of executing the job and sending the emails, these two records are deleted, and two new replacement records are inserted with queue = DEFAULT. I have no idea why.

class NewsletterService
{
    public function sendMail(Builder $users, array $inputs): void
    {
        $chunkIndex = 1;
        $users->chunk(config('custom.chunks.newsletters', 1), function ($users) use ($inputs, &$chunkIndex) {
            foreach ($users as $user) {
                SendNewsletterEmail::dispatch('newsletters_' . $chunkIndex, $user->email, $inputs['subject'], $inputs['body'])
                ->onQueue('newsletters_' . $chunkIndex);
            }
            $chunkIndex++;
        });
    }
}
0 likes
0 replies

Please or to participate in this conversation.