| 140 | routing_key=type.replace('-', '.'), **kwargs) |
| 141 | |
| 142 | def _publish(self, event, producer, routing_key, retry=False, |
| 143 | retry_policy=None, utcoffset=utcoffset): |
| 144 | exchange = self.exchange |
| 145 | try: |
| 146 | producer.publish( |
| 147 | event, |
| 148 | routing_key=routing_key, |
| 149 | exchange=exchange.name, |
| 150 | retry=retry, |
| 151 | retry_policy=retry_policy, |
| 152 | declare=[exchange], |
| 153 | serializer=self.serializer, |
| 154 | headers=self.headers, |
| 155 | delivery_mode=self.delivery_mode, |
| 156 | ) |
| 157 | except Exception as exc: # pylint: disable=broad-except |
| 158 | if not self.buffer_while_offline: |
| 159 | raise |
| 160 | self._outbound_buffer.append((event, routing_key, exc)) |
| 161 | |
| 162 | def send(self, type, blind=False, utcoffset=utcoffset, retry=False, |
| 163 | retry_policy=None, Event=Event, **fields): |