Update Consumer.php

webman-php · Feb 28, 2024 · 6fd491b · 6fd491b
1 parent 303d995
commit 6fd491b
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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);
                             }
                         });
                     }