Merge pull request #265 from php-enqueue/consumption-amqp-on-idle-not…

…-called [consumption][amqp] onIdle is never called.
php-enqueue · Nov 11, 2017 · 3f0e924 · 3f0e924
2 parents 705d489 + 59e215a
commit 3f0e924
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/pkg/enqueue/Consumption/QueueConsumer.php b/pkg/enqueue/Consumption/QueueConsumer.php
@@ -204,6 +204,9 @@ public function consume(ExtensionInterface $runtimeExtension = null)
                     }
 
                     $this->psrContext->consume($this->receiveTimeout);
+
+                    usleep($this->idleTimeout * 1000);
+                    $extension->onIdle($context);
                 } else {
                     /** @var PsrQueue $queue */
                     foreach ($this->boundProcessors as list($queue, $processor)) {