src/Queue/PdoQueue.php
function findByID($id, $queue = null)
    {
        $queue = $this->_normalizeQueueName($queue);

        try {
            $sql = "SELECT * FROM `{$this->table}` WHERE `queue_name` = '$queue' and `task_id` = '$id';";

            $stm = $this->conn->prepare($sql);
            $stm->execute();
            $stm->setFetchMode(\PDO::FETCH_ASSOC);

            if (! $queued = $stm->fetch() )
                return null;

        } catch (\Exception $e) {
            throw new exReadError('Error While Read From MySql Client.', $e->getCode(), $e);
        }


        $payload = unserialize($queued['payload']);
        return $payload;
    }
function findByID($id, $queue = null)
    {
        $queue = $this->_normalizeQueueName($queue);

        try {
            $sql = "SELECT * FROM `{$this->table}` WHERE `queue_name` = '$queue' and `task_id` = '$id';";

            $stm = $this->conn->prepare($sql);
            $stm->execute();
            $stm->setFetchMode(\PDO::FETCH_ASSOC);

            if (! $queued = $stm->fetch() )
                return null;

        } catch (\Exception $e) {
            throw new exReadError('Error While Read From MySql Client.', $e->getCode(), $e);
        }


        $payload = unserialize($queued['payload']);
        return $payload;
    }
Find Queued Payload By Given ID

@param string $id
@param string $queue

@return iPayloadQueued|null
@throws exIOError