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);
                             }
                         });
                     }