From 36589eb67507522c93c132968d1c5863db4d66cf Mon Sep 17 00:00:00 2001 From: SajtiDH Date: Fri, 26 Jan 2024 09:44:40 +0100 Subject: [PATCH 1/2] Delete job only it matches the driver and was not released previously --- src/Integrations/LaravelServiceProvider.php | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/src/Integrations/LaravelServiceProvider.php b/src/Integrations/LaravelServiceProvider.php index 8eeab11..8849d96 100644 --- a/src/Integrations/LaravelServiceProvider.php +++ b/src/Integrations/LaravelServiceProvider.php @@ -25,7 +25,11 @@ public function boot() ]); Queue::after(function (JobProcessed $event) { - $event->job->delete(); + if ($event->job->getConnectionName() === 'sqs-plain') { + if (!$event->job->isReleased()) { + $event->job->delete(); + } + } }); } From d2c096030e659b6afa8443dfe1c420e6aa692428 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?J=C3=A1nos=20Hajdu?= <40004107+SajtiDH@users.noreply.github.com> Date: Thu, 28 Mar 2024 11:13:41 +0100 Subject: [PATCH 2/2] Update src/Integrations/LaravelServiceProvider.php Co-authored-by: Kyle Nash --- src/Integrations/LaravelServiceProvider.php | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/Integrations/LaravelServiceProvider.php b/src/Integrations/LaravelServiceProvider.php index 8849d96..179ffbb 100644 --- a/src/Integrations/LaravelServiceProvider.php +++ b/src/Integrations/LaravelServiceProvider.php @@ -26,7 +26,7 @@ public function boot() Queue::after(function (JobProcessed $event) { if ($event->job->getConnectionName() === 'sqs-plain') { - if (!$event->job->isReleased()) { + if (!$event->job->isDeletedOrReleased()) { $event->job->delete(); } }