From 6fd491b19acb006d60931724aa2577a046ccb612 Mon Sep 17 00:00:00 2001
From: walkor <walkor@users.noreply.github.com>
Date: Wed, 28 Feb 2024 15:21:52 +0800
Subject: [PATCH] Update Consumer.php

---
 src/Process/Consumer.php | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/Process/Consumer.php b/src/Process/Consumer.php
index 7bc95bc..1406ef3 100644
--- a/src/Process/Consumer.php
+++ b/src/Process/Consumer.php
@@ -72,7 +72,7 @@ public function onWorkerStart()
                         $connection->onConsumeFailure(function ($exeption, $package) {
                             $consumer = $this->_consumers[$package['queue']] ?? null;
                             if ($consumer && method_exists($consumer, 'onConsumeFailure')) {
-                                call_user_func([$consumer, 'onConsumeFailure'], $exeption, $package);
+                                return call_user_func([$consumer, 'onConsumeFailure'], $exeption, $package);
                             }
                         });
                     }