'Start consuming from a queue
**Example request**:
.. sourcecode:: http
POST /api/worker/queue/add-consumer/celery@worker2?queue=sample-queue
Content-Length: 0
Content-Type: application/x-www-form-urlencoded; charset=utf-8
Host: localhost:5555
**Example response**:
.. sourcecode:: http
HTTP/1.1 200 OK
Content-Length: 40
Content-Type: application/json; charset=UTF-8
"message": "add consumer sample-queue"
:query queue: the name of a new queue
:reqheader Authorization: optional OAuth token to authenticate
:statuscode 200: no error
:statuscode 401: unauthorized request
:statuscode 403: failed to add consumer
:statuscode 404: unknown worker'

@web.authenticated
def post(self, workername):

    if (not self.is_worker(workername)):
        raise web.HTTPError(404, ("Unknown    worker    '%s'" % workername))
    queue = self.get_argument('queue')
    logger.info("Adding    consumer    '%s'    to    worker    '%s'", queue, workername)
    response = self.capp.control.broadcast('add_consumer', arguments={'queue': queue}, destination=[workername], reply=True)
    if (response and ('ok' in response[0][workername])):
        self.write(dict(message=response[0][workername]['ok']))
    else:
        logger.error(response)
        self.set_status(403)
        self.write(("Failed    to    add    '%s'    consumer    to    '%s'    worker:    %s" % (queue, workername, self.error_reason(workername, response))))
