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())]);