Exception handling for outbox thread

merge-requests/30/head
Bob Mottram 2022-02-22 11:11:55 +00:00
parent a81bf011f6
commit 2813cd49de
1 changed files with 6 additions and 2 deletions

View File

@ -1526,8 +1526,12 @@ class PubServer(BaseHTTPRequestHandler):
# remove any existing thread from the current index in the buffer
if self.server.outboxThread.get(account_outbox_thread_name):
acct = account_outbox_thread_name
if self.server.outboxThread[acct][index].is_alive():
self.server.outboxThread[acct][index].kill()
if self.server.outboxThread[acct].get(index):
try:
if self.server.outboxThread[acct][index].is_alive():
self.server.outboxThread[acct][index].kill()
except BaseException:
pass
return index
def _post_to_outbox_thread(self, message_json: {}) -> bool: