make appservice more resilient
This commit is contained in:
parent
d13ab94d4b
commit
11846eda79
|
@ -223,8 +223,12 @@ class Appservice:
|
||||||
def receive_messages(
|
def receive_messages(
|
||||||
appservice: Appservice, msg_queue: message_queue.MessageQueue
|
appservice: Appservice, msg_queue: message_queue.MessageQueue
|
||||||
):
|
):
|
||||||
|
while True:
|
||||||
|
try:
|
||||||
for message in msg_queue:
|
for message in msg_queue:
|
||||||
appservice.process_message(message)
|
appservice.process_message(message)
|
||||||
|
except Exception as e:
|
||||||
|
LOG.exception(e)
|
||||||
|
|
||||||
|
|
||||||
def main():
|
def main():
|
||||||
|
|
Loading…
Reference in New Issue