Skip to content
Snippets Groups Projects
Commit ccec2a95 authored by Jorrit Schaap's avatar Jorrit Schaap
Browse files

Task #8887: otdb_notification_busname

parent 4ab4b45c
No related branches found
No related tags found
No related merge requests found
...@@ -164,9 +164,9 @@ class RATaskSpecified(OTDBBusListener): ...@@ -164,9 +164,9 @@ class RATaskSpecified(OTDBBusListener):
notification_busname=DEFAULT_RA_TASK_SPECIFIED_NOTIFICATION_BUSNAME, notification_busname=DEFAULT_RA_TASK_SPECIFIED_NOTIFICATION_BUSNAME,
notification_subject=DEFAULT_RA_TASK_SPECIFIED_NOTIFICATION_SUBJECT, notification_subject=DEFAULT_RA_TASK_SPECIFIED_NOTIFICATION_SUBJECT,
**kwargs): **kwargs):
super(RATaskSpecified, self).__init__(busname=otdb_busname, subject=otdb_notification_subject, **kwargs) super(RATaskSpecified, self).__init__(busname=otdb_notification_busname, subject=otdb_notification_subject, **kwargs)
self.parset_rpc = RPC(service="TaskSpecification", busname=otdb_busname) self.parset_rpc = RPC(service="TaskSpecification", busname=otdb_notification_busname)
self.send_bus = ToBus("%s/%s" % (notification_busname, notification_subject)) self.send_bus = ToBus("%s/%s" % (notification_busname, notification_subject))
def start_listening(self, **kwargs): def start_listening(self, **kwargs):
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment