Method select

celery/app/amqp.py:168–177

Select a subset of currently defined queues to consume from. Arguments: include (Sequence[str], str): Names of queues to consume from.

(self, include)

        return q

    def select(self, include):
        """Select a subset of currently defined queues to consume from.

        Arguments:
            include (Sequence[str], str): Names of queues to consume from.
        """
        if include:
            self._consume_from = {
                name: self[name] for name in maybe_list(include)
            }

    def deselect(self, exclude):
        """Deselect queues so that they won't be consumed from.