src/Queue/PdoQueue.php
function release($id, $queue = null)
    {
        if ( $id instanceof iPayloadQueued ) {
            $arg   = $id;
            $id    = $arg->getUID();
            $queue = $arg->getQueue();
        }


        $queue = $this->_normalizeQueueName($queue);

        try {

            $sql = "DELETE FROM `{$this->table}` WHERE `task_id` = '{$id}' and `queue_name` = '{$queue}';";
            $this->conn->exec($sql);

        } catch (\Exception $e) {
            throw new exWriteError('Error While Delete From MySql Client.', $e->getCode(), $e);
        }
    }
function release($id, $queue = null)
    {
        if ( $id instanceof iPayloadQueued ) {
            $arg   = $id;
            $id    = $arg->getUID();
            $queue = $arg->getQueue();
        }


        $queue = $this->_normalizeQueueName($queue);

        try {

            $sql = "DELETE FROM `{$this->table}` WHERE `task_id` = '{$id}' and `queue_name` = '{$queue}';";
            $this->conn->exec($sql);

        } catch (\Exception $e) {
            throw new exWriteError('Error While Delete From MySql Client.', $e->getCode(), $e);
        }
    }
function release ( $ id , $ queue = null ) { if ( $ id instanceof iPayloadQueued ) { $ arg = $ id ; $ id = $ arg -> getUID ( ) ; $ queue = $ arg -> getQueue ( ) ; } $ queue = $ this -> _normalizeQueueName ( $ queue ) ; try { $ sql = "DELETE FROM `{$this->table}` WHERE `task_id` = '{$id}' and `queue_name` = '{$queue}';" ; $ this -> conn -> exec ( $ sql ) ; } catch ( \ Exception $ e ) { throw new exWriteError ( 'Error While Delete From MySql Client.' , $ e -> getCode ( ) , $ e ) ; } }
Release an Specific From Queue By Removing It

@param iPayloadQueued|string $id
@param null|string           $queue

@return void
@throws exIOError
Release an Specific From Queue By Removing It