'Add new task queue that\'ll be consumed from.
The queue will be active even when a subset has been selected
using the :option:`celery worker -Q` option.'

def select_add(self, queue, **kwargs):

    q = self.add(queue, **kwargs)
    if (self._consume_from is not None):
        self._consume_from[q.name] = q
    return q
