[mrjavadseydi]

When a unique queued listener is dispatched, Dispatcher::queueHandler() acquires the unique lock before pushing it to the queue. If the push throws (queue database or redis is down) the lock is never released, so every dispatch after that is silently skiped untill the lock expires, even after the queue is back.

class SendInvoice implements ShouldQueue, ShouldBeUnique
{
    public function handle(OrderPlaced $event)
    {
        // ...
    }
}

event(new OrderPlaced($order)); // throws, queue is down

// queue is back up

event(new OrderPlaced($order)); // silently skipped until the lock expires

Jobs already got this fix in #62010, this does the same for listeners. everything after the lock is acquired is wrapped so the lock gets released if anything throws, then the exeption is rethrown:

try {
    // resolve connection, queue, delay...

    is_null($delay)
        ? $connection->pushOn(enum_value($queue), $job)
        : $connection->laterOn(enum_value($queue), $delay, $job);
} catch (Throwable $e) {
    if ($job->shouldBeUnique) {
        (new UniqueLock($this->container->make(Cache::class)))->release($job);
    }

    throw $e;
}

Added a test that use a failing queue connection, same as the one in #62010.

[github-actions]

Thanks for submitting a PR!

Note that draft PRs are not reviewed. If you would like a review, please mark your pull request as ready for review in the GitHub user interface.

Pull requests that are abandoned in draft may be closed due to inactivity.