From cdd61db1fcdd2cc4f6ff39d65476eae7a4a10afc Mon Sep 17 00:00:00 2001
From: Jorrit Schaap <schaap@astron.nl>
Date: Tue, 8 Feb 2022 16:26:31 +0100
Subject: [PATCH] TMSS-1522: wrap in BusListenerJanitor to auto-delete queue
upon exit
---
CEP/TBB/TBBdatawriter/TBBTMSSBusListener.py | 5 ++++-
1 file changed, 4 insertions(+), 1 deletion(-)
diff --git a/CEP/TBB/TBBdatawriter/TBBTMSSBusListener.py b/CEP/TBB/TBBdatawriter/TBBTMSSBusListener.py
index 1e37074cb5a..ed91501cfab 100644
--- a/CEP/TBB/TBBdatawriter/TBBTMSSBusListener.py
+++ b/CEP/TBB/TBBdatawriter/TBBTMSSBusListener.py
@@ -1,5 +1,6 @@
#!/usr/bin/env python
+from lofar.messaging.messagebus import BusListenerJanitor
from lofar.sas.tmss.client.tmssbuslistener import TMSSBusListener, TMSSEventMessageHandler
from lofar.sas.tmss.client.tmss_http_rest_client import TMSSsession
from lofar.common.util import waitForInterrupt
@@ -188,7 +189,9 @@ def main():
else:
print("No observation running, waiting for next observation")
- with TMSSBusListener(handler_type=TBBTMSSEventMessageHandler, num_threads=1):
+ # run TMSSBusListener with TBBTMSSEventMessageHandler
+ # wrap in BusListenerJanitor to auto-delete queue upon exit
+ with BusListenerJanitor(TMSSBusListener(handler_type=TBBTMSSEventMessageHandler, num_threads=1)):
waitForInterrupt()
if __name__ == '__main__':
--
GitLab