(self, name, **options)
| 121 | return self._add(queue) |
| 122 | |
| 123 | def add_compat(self, name, **options): |
| 124 | # docs used to use binding_key as routing key |
| 125 | options.setdefault('routing_key', options.get('binding_key')) |
| 126 | if options['routing_key'] is None: |
| 127 | options['routing_key'] = name |
| 128 | return self._add(Queue.from_dict(name, **options)) |
| 129 | |
| 130 | def _add(self, queue): |
| 131 | if queue.exchange is None or queue.exchange.name == '': |