Added usleep 200ms when no messages are recieved

rosamarsky · rosamarsky · commit fec6fc02b297 · 2018-10-18T18:40:38.000+03:00
diff --git a/pkg/dbal/DbalSubscriptionConsumer.php b/pkg/dbal/DbalSubscriptionConsumer.php
@@ -77,6 +77,8 @@ public function consume(int $timeout = 0): void
                 unset($currentQueueNames[$message['queue']]);
             } else {
                 $currentQueueNames = [];
+
+                usleep(200000); // 200ms
             }
 
             if ($timeout && microtime(true) >= $endAt) {

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