(
self, queues=None, default_exchange=None,
create_missing=True, create_missing_queue_type=None,
create_missing_queue_exchange_type=None, autoexchange=None,
max_priority=None, default_routing_key=None,
)
| 61 | _consume_from = None |
| 62 | |
| 63 | def __init__( |
| 64 | self, queues=None, default_exchange=None, |
| 65 | create_missing=True, create_missing_queue_type=None, |
| 66 | create_missing_queue_exchange_type=None, autoexchange=None, |
| 67 | max_priority=None, default_routing_key=None, |
| 68 | ): |
| 69 | super().__init__() |
| 70 | self.aliases = WeakValueDictionary() |
| 71 | self.default_exchange = default_exchange |
| 72 | self.default_routing_key = default_routing_key |
| 73 | self.create_missing = create_missing |
| 74 | self.create_missing_queue_type = create_missing_queue_type |
| 75 | self.create_missing_queue_exchange_type = create_missing_queue_exchange_type |
| 76 | self.autoexchange = Exchange if autoexchange is None else autoexchange |
| 77 | self.max_priority = max_priority |
| 78 | if queues is not None and not isinstance(queues, Mapping): |
| 79 | queues = {q.name: q for q in queues} |
| 80 | queues = queues or {} |
| 81 | for name, q in queues.items(): |
| 82 | self.add(q) if isinstance(q, Queue) else self.add_compat(name, **q) |
| 83 | |
| 84 | def __getitem__(self, name): |
| 85 | try: |
nothing calls this directly
no test coverage detected