Deselect queues so that they won't be consumed from. Arguments: exclude (Sequence[str], str): Names of queues to avoid consuming from.
(self, exclude)
| 177 | } |
| 178 | |
| 179 | def deselect(self, exclude): |
| 180 | """Deselect queues so that they won't be consumed from. |
| 181 | |
| 182 | Arguments: |
| 183 | exclude (Sequence[str], str): Names of queues to avoid |
| 184 | consuming from. |
| 185 | """ |
| 186 | if exclude: |
| 187 | exclude = maybe_list(exclude) |
| 188 | if self._consume_from is None: |
| 189 | # using all queues |
| 190 | return self.select(k for k in self if k not in exclude) |
| 191 | # using selection |
| 192 | for queue in exclude: |
| 193 | self._consume_from.pop(queue, None) |
| 194 | |
| 195 | def new_missing(self, name): |
| 196 | queue_arguments = None |