Problem: Timeout value for queue read too small

Solution: Increase timeout
This commit is contained in:
Vanshdeep Singh 2018-07-31 16:37:43 +02:00
parent 5ecd8fb57c
commit eeda027cea

View File

@ -67,7 +67,7 @@ class Exchange:
""" """
try: try:
self.started_queue.get(timeout=0.01) self.started_queue.get(timeout=1)
raise RuntimeError('Cannot create a new subscriber queue while Exchange is running.') raise RuntimeError('Cannot create a new subscriber queue while Exchange is running.')
except Empty: except Empty:
pass pass