Like propagate(message).wait_for_response(), but will also propagate any resulting MessageHandlingError back.
(self, message)
| 1278 | self.send_event(message.event, message.body) |
| 1279 | |
| 1280 | def delegate(self, message): |
| 1281 | """Like propagate(message).wait_for_response(), but will also propagate |
| 1282 | any resulting MessageHandlingError back. |
| 1283 | """ |
| 1284 | try: |
| 1285 | result = self.propagate(message) |
| 1286 | if result.is_request(): |
| 1287 | result = result.wait_for_response() |
| 1288 | return result |
| 1289 | except MessageHandlingError as exc: |
| 1290 | exc.propagate(message) |
| 1291 | |
| 1292 | def _parse_incoming_messages(self): |
| 1293 | log.debug("Starting message loop for channel {0}", self) |
no test coverage detected