diff --git a/bigchaindb/events.py b/bigchaindb/events.py index 7959d284..e60fe44f 100644 --- a/bigchaindb/events.py +++ b/bigchaindb/events.py @@ -67,7 +67,7 @@ class Exchange: """ try: - self.started_queue.get_nowait() + self.started_queue.get(timeout=0.01) raise RuntimeError('Cannot create a new subscriber queue while Exchange is running.') except Empty: pass