Mar 2, 2025
0
Level 1
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++;
});
}
}
Please or to participate in this conversation.