src/Queue/AggregateQueue.php
function findByID($id, $queue = null)
    {
        if ($queue === null)
        {
            $payload = null;

            /** @var iQueueDriver $queue */
            foreach ($this->channels_queue as $channel => $queue ) {
                if ( $payload = $queue->findByID($id, $channel) )
                    break;
            }

        } else {
            if (false === $qd = $this->_getQueueOfChannel($queue) )
                throw new \RuntimeException(sprintf(
                    'Channel (%s) is not present when trying to find: (%s).'
                    , $queue ,\Poirot\Std\flatten($id)
                ));


            $payload = $qd->findByID($id, $queue);
        }

        return $payload;
    }
function findByID($id, $queue = null)
    {
        if ($queue === null)
        {
            $payload = null;

            /** @var iQueueDriver $queue */
            foreach ($this->channels_queue as $channel => $queue ) {
                if ( $payload = $queue->findByID($id, $channel) )
                    break;
            }

        } else {
            if (false === $qd = $this->_getQueueOfChannel($queue) )
                throw new \RuntimeException(sprintf(
                    'Channel (%s) is not present when trying to find: (%s).'
                    , $queue ,\Poirot\Std\flatten($id)
                ));


            $payload = $qd->findByID($id, $queue);
        }

        return $payload;
    }
function findByID ( $ id , $ queue = null ) { if ( $ queue === null ) { $ payload = null ; /** @var iQueueDriver $queue */ foreach ( $ this -> channels_queue as $ channel => $ queue ) { if ( $ payload = $ queue -> findByID ( $ id , $ channel ) ) break ; } } else { if ( false === $ qd = $ this -> _getQueueOfChannel ( $ queue ) ) throw new \ RuntimeException ( sprintf ( 'Channel (%s) is not present when trying to find: (%s).' , $ queue , \ Poirot \ Std \ flatten ( $ id ) ) ) ; $ payload = $ qd -> findByID ( $ id , $ queue ) ; } 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