diff --git a/src/Consumer.php b/src/Consumer.php index cb9ddc2..6c0bebc 100644 --- a/src/Consumer.php +++ b/src/Consumer.php @@ -145,7 +145,7 @@ public function listenToQueue($handlerClass, BowlerExceptionHandler $exceptionHa try { $queueHandler->handle($message); - $broker->ackMessage($message); + $broker->ackMessage(); } catch (\Exception $e) { $exceptionHandler->reportError($e, $message);