diff --git a/src/RabbitContext.php b/src/RabbitContext.php index 8c0c0f4..e27012d 100644 --- a/src/RabbitContext.php +++ b/src/RabbitContext.php @@ -140,6 +140,7 @@ public function jeTraiteJobsAvecLeConsumer($nb_jobs, $consumer) $consumer = $this->getContainer()->get("old_sound_rabbit_mq.{$consumer}_consumer"); $consumer->consume($nb_jobs); + $consumer->resetConsumed(); $consumer->getChannel()->close(); }