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

def select(self, include):

    if include:
        self._consume_from = {name: self[name] for name in maybe_list(include)}
