Headless queue consumer for ntor