Fixed bug in socket client

This commit is contained in:
aewens 2019-05-18 15:03:23 -05:00
parent d271de75dc
commit 09c8958c3d
1 changed files with 1 additions and 1 deletions

View File

@ -84,7 +84,7 @@ class SocketClient(Thread):
def _queue_thread(self, inbox, timeout):
while not self.kill_switch.is_set():
for message in self._obtain(inbox, timeout):
for message in self._obtain("inbox", timeout):
if self.broken.is_set():
self.reconnecting.wait()
self.send_message(message)