rx: Use opr queues