diff --git a/SAS/ResourceAssignment/Services/src/RABusListener.py b/SAS/ResourceAssignment/Services/src/RABusListener.py index efa49c6172c3eaa346d0fbaa06bcfdc0a2b44e0b..ff61518e26ee3be5f5773ea446fe068336bd016e 100644 --- a/SAS/ResourceAssignment/Services/src/RABusListener.py +++ b/SAS/ResourceAssignment/Services/src/RABusListener.py @@ -65,9 +65,9 @@ class RATaskSpecifiedBusListener(AbstractBusListener): resource_indicators = msg.content['resource_indicators'] - self.onMessage(sasId, modificationTime, resource_indicators) + self.onTaskSpecified(sasId, modificationTime, resource_indicators) - def onMessage(self, sasId, modificationTime, resourceIndicators): + def onTaskSpecified(self, sasId, modificationTime, resourceIndicators): pass __all__ = ["RATaskSpecifiedBusListener"] diff --git a/SAS/ResourceAssignment/Services/test/tRATaskSpecified.py b/SAS/ResourceAssignment/Services/test/tRATaskSpecified.py index a4919e79f57dcd2f1f088167f58e3a938deac3f6..b392cb382ea2efbaff9f09ec35759053801a6e76 100644 --- a/SAS/ResourceAssignment/Services/test/tRATaskSpecified.py +++ b/SAS/ResourceAssignment/Services/test/tRATaskSpecified.py @@ -117,7 +117,7 @@ class TestService(unittest.TestCase): self.lock = Lock() self.cond = Condition(self.lock) - def onMessage(self, sasId, modificationTime, resourceIndicators): + def onTaskSpecified(self, sasId, modificationTime, resourceIndicators): self.messageReceived = True self.sasID = sasId @@ -146,7 +146,7 @@ class TestService(unittest.TestCase): 3 requires nothing """ - with RATaskSpecified("TaskSpecified", otdb_busname=self.busname, my_busname=self.busname) as jts: + with RATaskSpecified("OTDB.TaskSpecified", otdb_busname=self.busname, my_busname=self.busname) as jts: # Send fake status update with ToBus(self.status_service) as tb: msg = EventMessage(content={ @@ -177,7 +177,7 @@ class TestService(unittest.TestCase): 3 requires nothing """ - with RATaskSpecified("TaskSpecified", otdb_busname=self.busname, my_busname=self.busname) as jts: + with RATaskSpecified("OTDB.TaskSpecified", otdb_busname=self.busname, my_busname=self.busname) as jts: # Send fake status update with ToBus(self.status_service) as tb: msg = EventMessage(content={