Skip to content
Snippets Groups Projects
Commit ada6e1b7 authored by Jan David Mol's avatar Jan David Mol
Browse files

Task #8888: onMessage -> onTaskSpecified

parent a4d67a1f
No related branches found
No related tags found
No related merge requests found
......@@ -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"]
......@@ -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={
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment