diff --git a/SAS/MoM/MoMQueryService/momqueryrpc.py b/SAS/MoM/MoMQueryService/momqueryrpc.py index 0514fa2d3dd8529ba8fee881fee3dbd1766e82a7..fe8cead053035119a9f09c290878a5ff19240c70 100644 --- a/SAS/MoM/MoMQueryService/momqueryrpc.py +++ b/SAS/MoM/MoMQueryService/momqueryrpc.py @@ -12,7 +12,7 @@ from lofar.mom.momqueryservice.config import DEFAULT_BUSNAME, DEFAULT_SERVICENAM logger = logging.getLogger(__file__) -class MoMRPC(RPCWrapper): +class MoMQueryRPC(RPCWrapper): def getProjectDetails(self, ids): '''get the project details for one or more mom ids :param ids single or list of mom ids @@ -57,7 +57,7 @@ def main(): logging.basicConfig(format='%(asctime)s %(levelname)s %(message)s', level=logging.INFO if options.verbose else logging.WARN) - with MoMRPC(busname=options.busname, servicename=options.servicename, broker=options.broker) as rpc: + with MoMQueryRPC(busname=options.busname, servicename=options.servicename, broker=options.broker) as rpc: if options.projects: projects = rpc.getProjects() for project in projects: diff --git a/SAS/MoM/MoMQueryService/test/test_momqueryservice.py b/SAS/MoM/MoMQueryService/test/test_momqueryservice.py index 0f160df6d0b44507278c40d0835b7f23c356b3d6..54629e1a3aea606256cd70824bf01feec0b59952 100755 --- a/SAS/MoM/MoMQueryService/test/test_momqueryservice.py +++ b/SAS/MoM/MoMQueryService/test/test_momqueryservice.py @@ -24,7 +24,7 @@ import uuid import logging from lofar.mom.momqueryservice.momqueryservice import createService from lofar.mom.momqueryservice.momqueryservice import ProjectDetailsQueryHandler -from lofar.mom.momqueryservice.momqueryrpc import MoMRPC +from lofar.mom.momqueryservice.momqueryrpc import MoMQueryRPC from lofar.mom.momqueryservice.config import DEFAULT_SERVICENAME from qpid.messaging import Connection from qpidtoollibs import BrokerAgent @@ -56,7 +56,7 @@ try: # inject the mock into the service with createService(busname, handler=MockProjectDetailsQueryHandler), \ - MoMRPC(busname, DEFAULT_SERVICENAME) as momrpc: + MoMQueryRPC(busname, DEFAULT_SERVICENAME) as momrpc: class TestLTAStorageDb(unittest.TestCase): def testProjectDetailsQuery(self): diff --git a/SAS/ResourceAssignment/RAtoOTDBTaskSpecificationPropagator/lib/propagator.py b/SAS/ResourceAssignment/RAtoOTDBTaskSpecificationPropagator/lib/propagator.py index 940feeaeaf86a201f8877dbcab5e59edf1834704..d5063aee96eb134a191e03a45ce93d91c2c386d7 100755 --- a/SAS/ResourceAssignment/RAtoOTDBTaskSpecificationPropagator/lib/propagator.py +++ b/SAS/ResourceAssignment/RAtoOTDBTaskSpecificationPropagator/lib/propagator.py @@ -40,7 +40,7 @@ from lofar.sas.resourceassignment.ratootdbtaskspecificationpropagator.otdbrpc im from lofar.sas.otdb.config import DEFAULT_OTDB_SERVICE_BUSNAME, DEFAULT_OTDB_SERVICENAME from lofar.sas.resourceassignment.ratootdbtaskspecificationpropagator.translator import RAtoOTDBTranslator -from lofar.mom.momqueryservice.momqueryrpc import MoMRPC +from lofar.mom.momqueryservice.momqueryrpc import MoMQueryRPC from lofar.mom.momqueryservice.config import DEFAULT_BUSNAME as DEFAULT_MOM_BUSNAME from lofar.mom.momqueryservice.config import DEFAULT_SERVICENAME as DEFAULT_MOM_SERVICENAME @@ -76,7 +76,7 @@ class RAtoOTDBPropagator(): self.radbrpc = RADBRPC(busname=radb_busname, servicename=radb_servicename, broker=radb_broker) ## , ForwardExceptions=True hardcoded in RPCWrapper right now self.otdbrpc = OTDBRPC(busname=otdb_busname, servicename=otdb_servicename, broker=otdb_broker) ## , ForwardExceptions=True hardcoded in RPCWrapper right now - self.momrpc = MoMRPC(busname=mom_busname, servicename=mom_servicename, broker=mom_broker) + self.momrpc = MoMQueryRPC(busname=mom_busname, servicename=mom_servicename, broker=mom_broker) self.translator = RAtoOTDBTranslator() def __enter__(self): diff --git a/SAS/ResourceAssignment/ResourceAssignmentEditor/lib/radbchangeshandler.py b/SAS/ResourceAssignment/ResourceAssignmentEditor/lib/radbchangeshandler.py index a03b616714988c5f739846e1290ecff208543b01..1550d9a98568d24c377f4401c1558614f8579561 100644 --- a/SAS/ResourceAssignment/ResourceAssignmentEditor/lib/radbchangeshandler.py +++ b/SAS/ResourceAssignment/ResourceAssignmentEditor/lib/radbchangeshandler.py @@ -30,7 +30,7 @@ Typical usage is to derive your own subclass from RADBChangesHandler and impleme from lofar.sas.resourceassignment.database.config import DEFAULT_NOTIFICATION_BUSNAME, DEFAULT_NOTIFICATION_SUBJECTS from lofar.sas.resourceassignment.database.radbbuslistener import RADBBusListener from lofar.common.util import waitForInterrupt -from lofar.mom.momqueryservice.momqueryrpc import MoMRPC +from lofar.mom.momqueryservice.momqueryrpc import MoMQueryRPC from lofar.mom.momqueryservice.config import DEFAULT_BUSNAME as DEFAULT_MOM_BUSNAME from lofar.mom.momqueryservice.config import DEFAULT_SERVICENAME as DEFAULT_MOM_SERVICENAME from lofar.sas.resourceassignment.resourceassignmenteditor.mom import updateTaskMomDetails diff --git a/SAS/ResourceAssignment/ResourceAssignmentEditor/lib/webservice.py b/SAS/ResourceAssignment/ResourceAssignmentEditor/lib/webservice.py index 3d99008973401eec49189110244bd7e62961e4dd..241743366faa54fda0f33da4568b82dabdfd09e0 100755 --- a/SAS/ResourceAssignment/ResourceAssignmentEditor/lib/webservice.py +++ b/SAS/ResourceAssignment/ResourceAssignmentEditor/lib/webservice.py @@ -47,7 +47,7 @@ from lofar.sas.resourceassignment.database.config import DEFAULT_NOTIFICATION_SU from lofar.sas.resourceassignment.resourceassignmentservice.rpc import RARPC from lofar.sas.resourceassignment.resourceassignmentservice.config import DEFAULT_BUSNAME as DEFAULT_RADB_BUSNAME from lofar.sas.resourceassignment.resourceassignmentservice.config import DEFAULT_SERVICENAME as DEFAULT_RADB_SERVICENAME -from lofar.mom.momqueryservice.momqueryrpc import MoMRPC +from lofar.mom.momqueryservice.momqueryrpc import MoMQueryRPC from lofar.mom.momqueryservice.config import DEFAULT_BUSNAME as DEFAULT_MOM_BUSNAME from lofar.mom.momqueryservice.config import DEFAULT_SERVICENAME as DEFAULT_MOM_SERVICENAME from lofar.sas.resourceassignment.resourceassignmenteditor.mom import updateTaskMomDetails @@ -333,7 +333,7 @@ def main(): global rarpc rarpc = RARPC(busname=DEFAULT_RADB_BUSNAME, servicename=DEFAULT_RADB_SERVICENAME, broker=options.broker) global momrpc - momrpc = MoMRPC(busname=DEFAULT_MOM_BUSNAME, servicename=DEFAULT_MOM_SERVICENAME, timeout=2.5, broker=options.broker) + momrpc = MoMQueryRPC(busname=DEFAULT_MOM_BUSNAME, servicename=DEFAULT_MOM_SERVICENAME, timeout=2.5, broker=options.broker) global radbchangeshandler radbchangeshandler = RADBChangesHandler(DEFAULT_RADB_CHANGES_BUSNAME, broker=options.broker, momrpc=momrpc)