src/Queue/MongoQueue.php
function findByID($id, $queue = null)
    {
        try {
            $queued = $this->collection->findOne(
                [
                    '_id'   => new MongoDB\BSON\ObjectID( (string) $id),
                    'queue' => $this->_normalizeQueueName($queue),
                ]
                , [
                    // override typeMap option
                    'typeMap' => self::$typeMap,
                ]
            );
        } catch (\Exception $e) {
            throw new exReadError('Error While Write To Mongo Client.', $e->getCode(), $e);
        }


        if (! $queued )
            return null;


        $payload = $this->_interchangeable()
            ->retrieveBackward($queued['payload']);

        $payload = $payload->withQueue($queue)
            ->withUID( (string) $queued['_id'] );

        return $payload;
    }
function findByID($id, $queue = null)
    {
        try {
            $queued = $this->collection->findOne(
                [
                    '_id'   => new MongoDB\BSON\ObjectID( (string) $id),
                    'queue' => $this->_normalizeQueueName($queue),
                ]
                , [
                    // override typeMap option
                    'typeMap' => self::$typeMap,
                ]
            );
        } catch (\Exception $e) {
            throw new exReadError('Error While Write To Mongo Client.', $e->getCode(), $e);
        }


        if (! $queued )
            return null;


        $payload = $this->_interchangeable()
            ->retrieveBackward($queued['payload']);

        $payload = $payload->withQueue($queue)
            ->withUID( (string) $queued['_id'] );

        return $payload;
    }
function findByID ( $ id , $ queue = null ) { try { $ queued = $ this -> collection -> findOne ( [ '_id' => new MongoDB \ BSON \ ObjectID ( ( string ) $ id ) , 'queue' => $ this -> _normalizeQueueName ( $ queue ) , ] , [ // override typeMap option 'typeMap' => self :: $ typeMap , ] ) ; } catch ( \ Exception $ e ) { throw new exReadError ( 'Error While Write To Mongo Client.' , $ e -> getCode ( ) , $ e ) ; } if ( ! $ queued ) return null ; $ payload = $ this -> _interchangeable ( ) -> retrieveBackward ( $ queued [ 'payload' ] ) ; $ payload = $ payload -> withQueue ( $ queue ) -> withUID ( ( string ) $ queued [ '_id' ] ) ; return $ payload ; }
Find Queued Payload By Given ID

@param string $id
@param string $queue

@return iPayloadQueued|null
@throws exIOError
Find Queued Payload By Given ID