Replace queue consumer

Update or create a consumer for the queue.