Merge pull request #26 from run-as-root/develop

Make plugin method arguments optional as in the original method
run-as-root · Apr 26, 2023 · 5c79e91 · 5c79e91
2 parents 80030f3 + 486f319
commit 5c79e91
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/src/Plugin/HandleQueueMessageRejectPlugin.php b/src/Plugin/HandleQueueMessageRejectPlugin.php
@@ -27,22 +27,22 @@ public function aroundReject(
         QueueInterface $subject,
         callable $proceed,
         EnvelopeInterface $envelope,
-        bool $requeue,
-        string $error
+        bool $requeue = true,
+        string $rejectionMessage = null
     ): void {
-        if (!$error) {
-            $proceed($envelope, $requeue, $error);
+        if (!$rejectionMessage) {
+            $proceed($envelope, $requeue, $rejectionMessage);
             return;
         }
 
         $shouldBeSavedForRetry = $this->isMessageShouldBeSavedForRetryService->execute($envelope);
 
         if (!$shouldBeSavedForRetry) {
-            $proceed($envelope, $requeue, $error);
+            $proceed($envelope, $requeue, $rejectionMessage);
             return;
         }
 
-        $this->saveFailedMessageService->execute($envelope, $error);
+        $this->saveFailedMessageService->execute($envelope, $rejectionMessage);
         $subject->acknowledge($envelope);
     }
 }