SW-699: Drop kwargs for BusListeners

SAS/ResourceAssignment/RAtoOTDBTaskSpecificationPropagator/lib/rotspservice.py

@@ -44,19 +44,13 @@ class RATaskStatusChangedListener(RABusListener):
     def __init__(self,
                  busname=DEFAULT_BUSNAME,
                  broker=DEFAULT_BROKER,
-                 propagator=None, ## TODO also give translator?
-                 **kwargs):
+                 propagator=None):
         """
         RATaskScheduledListener listens on the lofar ?? bus and calls onTaskScheduled or onTaskConclict
         :param busname: valid Qpid address (default: lofar.ra.notification)
         :param broker: valid Qpid broker host (default: None, which means localhost)
-        additional parameters in kwargs:
-                options=     <dict>    Dictionary of options passed to QPID
-                exclusive= <bool>    Create an exclusive binding so no other services can consume duplicate messages (default: False)
-                numthreads= <int>    Number of parallel threads processing messages (default: 1)
-                verbose=     <bool>    Output extra logging over stdout (default: False)
         """
-        super(RATaskStatusChangedListener, self).__init__(busname=busname, broker=broker, **kwargs)
+        super(RATaskStatusChangedListener, self).__init__(busname=busname, broker=broker)
 
         self.propagator = propagator
         if not self.propagator:

SAS/ResourceAssignment/ResourceAssigner/lib/raservice.py

@@ -42,19 +42,13 @@ class SpecifiedTaskListener(RATaskSpecifiedBusListener):
     def __init__(self,
                  busname=DEFAULT_BUSNAME,
                  broker=DEFAULT_BROKER,
-                 assigner=None,
-                 **kwargs):
+                 assigner=None):
         """
         SpecifiedTaskListener listens on the lofar ?? bus and calls onTaskSpecified
         :param busname: valid Qpid address (default: lofar.otdb.status)
         :param broker: valid Qpid broker host (default: None, which means localhost)
-        additional parameters in kwargs:
-                options=     <dict>    Dictionary of options passed to QPID
-                exclusive= <bool>    Create an exclusive binding so no other services can consume duplicate messages (default: False)
-                numthreads= <int>    Number of parallel threads processing messages (default: 1)
-                verbose=     <bool>    Output extra logging over stdout (default: False)
         """
-        super(SpecifiedTaskListener, self).__init__(busname=busname, broker=broker, **kwargs)
+        super(SpecifiedTaskListener, self).__init__(busname=busname, broker=broker)
 
         self.assigner = assigner
         if not self.assigner:

SAS/TriggerEmailService/Server/lib/TriggerEmailService.py

@@ -79,8 +79,8 @@ class MoMIdError(Exception):
 
 
 class OTDBTriggerListener(OTDBBusListener):
-    def __init__(self, momquery_rpc=MoMQueryRPC(), busname=DEFAULT_BUSNAME, broker=DEFAULT_BROKER, **kwargs):
-        super(OTDBTriggerListener, self).__init__(busname=busname, broker=broker, **kwargs)
+    def __init__(self, momquery_rpc=MoMQueryRPC(), busname=DEFAULT_BUSNAME, broker=DEFAULT_BROKER):
+        super(OTDBTriggerListener, self).__init__(busname=busname, broker=broker)
 
         self.mom_rpc_client = momquery_rpc