Updated queues

2022-01-06 17:32:07 +05:30 · 2022-01-06 17:32:07 +05:30 · 21691de95d
commit 21691de95d
parent 584ea0f6a0
1 changed files with 7 additions and 1 deletions
--- a/src/queues.py
+++ b/src/queues.py
@ -8,7 +8,13 @@ from six.moves import queue
 try:
    from multiqueue import MultiQueue
 except ImportError:
-    from .multiqueue import MultiQueue
+    try:
+        from .multiqueue import MultiQueue
+    except ImportError:
+        import sys
+        if 'bitmessagemock' not in sys.modules:
+            raise
+        MultiQueue = queue.Queue


 class ObjectProcessorQueue(queue.Queue):