Update MongodbConsumer.php

makasim · web-flow · commit d8b0850b9b56 · 2018-05-08T23:01:32.000+03:00
diff --git a/pkg/mongodb/MongodbConsumer.php b/pkg/mongodb/MongodbConsumer.php
@@ -137,6 +137,7 @@ protected function receiveMessage()
         $collection = $this->context->getCollection();
         $message = $collection->findOneAndDelete(
             [
+                'queue' => $this->queue->getName(),
                 '$or' => [
                     ['delayed_until' => ['$exists' => false]],
                     ['delayed_until' => ['$lte' => $now]],

Original file line number	Diff line number	Diff line change
`@@ -137,6 +137,7 @@ protected function receiveMessage()`
`137`	`137`	`$collection = $this->context->getCollection();`
`138`	`138`	`$message = $collection->findOneAndDelete(`
`139`	`139`	`[`
	`140`	`+ 'queue' => $this->queue->getName(),`
`140`	`141`	`'$or' => [`
`141`	`142`	`['delayed_until' => ['$exists' => false]],`
`142`	`143`	`['delayed_until' => ['$lte' => $now]],`