Added usleep 200ms when no messages are recieved

rosamarsky · rosamarsky · commit d0ea85f62301 · 2018-10-18T18:42:01.000+03:00
diff --git a/pkg/mongodb/MongodbSubscriptionConsumer.php b/pkg/mongodb/MongodbSubscriptionConsumer.php
@@ -76,6 +76,8 @@ public function consume(int $timeout = 0): void
                 unset($currentQueueNames[$result['queue']]);
             } else {
                 $currentQueueNames = [];
+
+                usleep(200000); // 200ms
             }
 
             if ($timeout && microtime(true) >= $endAt) {

Original file line number	Diff line number	Diff line change
`@@ -76,6 +76,8 @@ public function consume(int $timeout = 0): void`
`76`	`76`	`unset($currentQueueNames[$result['queue']]);`
`77`	`77`	`} else {`
`78`	`78`	`$currentQueueNames = [];`
	`79`	`+`
	`80`	`+ usleep(200000); // 200ms`
`79`	`81`	`}`
`80`	`82`
`81`	`83`	`if ($timeout && microtime(true) >= $endAt) {`