Merge pull request #46 from gdubost/v3

[HF] Improvement du consume de jobs
etna-alternance · Jun 25, 2019 · 652d154 · 652d154
2 parents 7ceda26 + 91b66bb
commit 652d154
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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();
     }