[consumption][amqp] onIdle is never called.

makasim · makasim · commit 59e215a14174 · 2017-11-10T18:22:47.000+02:00
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)) {

Original file line number	Diff line number	Diff line change
`@@ -204,6 +204,9 @@ public function consume(ExtensionInterface $runtimeExtension = null)`
`204`	`204`	`}`
`205`	`205`
`206`	`206`	`$this->psrContext->consume($this->receiveTimeout);`
	`207`	`+`
	`208`	`+ usleep($this->idleTimeout * 1000);`
	`209`	`+ $extension->onIdle($context);`
`207`	`210`	`} else {`
`208`	`211`	`/** @var PsrQueue $queue */`
`209`	`212`	`foreach ($this->boundProcessors as list($queue, $processor)) {`