make wsjt queue configurable

2019-09-12 15:32:54 +02:00
parent 25a1d06dcb
commit a11875145b
2 changed files with 13 additions and 1 deletions
--- a/owrx/wsjt.py
+++ b/owrx/wsjt.py
@ -41,7 +41,8 @@ class WsjtQueue(Queue):
    @staticmethod
    def getSharedInstance():
        if WsjtQueue.sharedInstance is None:
-            WsjtQueue.sharedInstance = WsjtQueue(maxsize=10, workers=2)
+            pm = PropertyManager.getSharedInstance()
+            WsjtQueue.sharedInstance = WsjtQueue(maxsize=pm["wsjt_queue_length"], workers=pm["wsjt_queue_workers"])
        return WsjtQueue.sharedInstance

    def __init__(self, maxsize, workers):