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;
    }
Find Queued Payload By Given ID

@param string $id
@param string $queue

@return iPayloadQueued|null
@throws exIOError