diff --git a/src/RabbitContext.php b/src/RabbitContext.php index f9c8c29..2c7f264 100644 --- a/src/RabbitContext.php +++ b/src/RabbitContext.php @@ -145,6 +145,7 @@ public function jeTraiteJobsAvecLeConsumer($nb_jobs, $consumer) } self::$silex_app['rabbit.consumer'][$consumer]->consume($nb_jobs); + self::$silex_app['rabbit.consumer'][$consumer]->resetConsumed(); } /**