Skip to content

Commit

Permalink
Merge pull request #14 from php-enqueue/fix-queue-consumer-timeout
Browse files Browse the repository at this point in the history
[consumption][bug] Receive timeout is in milliseconds. Set it to 5000.…
  • Loading branch information
makasim authored Jan 13, 2017
2 parents 26df85b + 9eabb7c commit db15dd8
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion pkg/enqueue/Consumption/QueueConsumer.php
Original file line number Diff line number Diff line change
Expand Up @@ -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())]);
Expand Down

0 comments on commit db15dd8

Please sign in to comment.