From 91b66bb290997fc8cb3906c998b46fd2a043e9f2 Mon Sep 17 00:00:00 2001 From: Guillaume DUBOST Date: Tue, 25 Jun 2019 17:36:31 +0200 Subject: [PATCH] [HF] Improvement du consume de jobs --- src/RabbitContext.php | 1 + 1 file changed, 1 insertion(+) 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(); }