(self)
| 222 | raise e |
| 223 | |
| 224 | def close(self): |
| 225 | self.closed = True |
| 226 | self.auto_reconnect_enabled = False |
| 227 | self.disconnect() |
| 228 | if self.current_app_monitor.is_alive(): |
| 229 | self.current_app_monitor.shutdown() |
| 230 | if self.message_processor.is_alive(): |
| 231 | self.message_processor.shutdown() |
| 232 | self.message_workers.shutdown() |
| 233 | |
| 234 | def _on_message(self, message: str): |
| 235 | if self.logger.level <= logging.DEBUG: |