From 9eabb7ca0962d2864d40382c93fade3e81da8c41 Mon Sep 17 00:00:00 2001
From: Maksim Kotlyar <kotlyar.maksim@gmail.com>
Date: Fri, 13 Jan 2017 23:16:41 +0200
Subject: [PATCH] [consumption][bug] Receive timeout is in miliseconds. Set it
 to 5000. Five sec.

---
 pkg/enqueue/Consumption/QueueConsumer.php | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pkg/enqueue/Consumption/QueueConsumer.php b/pkg/enqueue/Consumption/QueueConsumer.php
index d65b73bf1..002fcd8b7 100644
--- a/pkg/enqueue/Consumption/QueueConsumer.php
+++ b/pkg/enqueue/Consumption/QueueConsumer.php
@@ -190,7 +190,7 @@ protected function doConsume(ExtensionInterface $extension, Context $context)
             throw new ConsumptionInterruptedException();
         }
 
-        if ($message = $consumer->receive($timeout = 1)) {
+        if ($message = $consumer->receive($timeout = 5000)) {
             $logger->info('Message received');
             $logger->debug('Headers: {headers}', ['headers' => new VarExport($message->getHeaders())]);
             $logger->debug('Properties: {properties}', ['properties' => new VarExport($message->getProperties())]);