RabbitMq.php
/**
     * Remove message from persistent queue
     * @param AMQPMessage $msg
     */
Remove message from persistent queue
@param AMQPMessage $msg
Remove message from persistent queue @param AMQPMessage $msg
public static function removeFromQueue($msg)
    {
        $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
    }
public static function removeFromQueue ( $ msg ) { $ msg -> delivery_info [ 'channel' ] -> basic_ack ( $ msg -> delivery_info [ 'delivery_tag' ] ) ; }
Remove message from persistent queue
 @param AMQPMessage $msg
Remove message from persistent queue @param AMQPMessage $msg
// TODO: message if not 'basic_ack' is owned by process until it dies - make possibility to release and requeue message on error in callback