for testing and deploying your application
for finding and fixing issues
for empowering human code reviews
<?php
/**
* Defines the TraderInteractive\Mongo\Queue class.
*/
namespace TraderInteractive\Mongo;
use MongoDB\BSON\UTCDateTime;
use MongoDB\Client;
* Abstraction of mongo db collection as priority queue.
*
* Tied priorities are ordered by time. So you may use a single priority for normal queuing (default args exist for
* this purpose). Using a random priority achieves random get()
final class Queue extends AbstractQueue implements QueueInterface
{
* Construct queue.
* @param \MongoDB\Collection|string $collectionOrUrl A MongoCollection instance or the mongo connection url.
* @param string $db the mongo db name
* @param string $collection the collection name to use for the queue
* @throws \InvalidArgumentException $collectionOrUrl, $db or $collection was not a string
public function __construct($collectionOrUrl, string $db = null, string $collection = null)
if ($collectionOrUrl instanceof \MongoDB\Collection) {
$this->collection = $collectionOrUrl;
return;
}
if (!is_string($collectionOrUrl)) {
throw new \InvalidArgumentException('$collectionOrUrl was not a string');
$this->collection = (new Client($collectionOrUrl))->selectDatabase($db)->selectCollection($collection);
traderinteractive /
mongo-queue-php
