(self)
| 161 | logger.error('Message queue is full, discard new messages') # todo: alert user |
| 162 | |
| 163 | def get_task_commands(self): |
| 164 | return self.unhandled_task_msgs.get() |
| 165 | |
| 166 | def _trigger_close_event(self): |
| 167 | """触发Backend on_session_close callback""" |