modules/fm-orchestrator
1
0
Fork 0
mirror of https://pagure.io/fm-orchestrator.git synced 2026-04-09 05:38:04 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

messaging: publish*, unify order of args, remove positional arg

Browse Source
This commit is contained in:
Lubos Kocman
2016-10-04 15:00:19 +02:00
parent b00ea5ac95
commit 452aba0373
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
rida/messaging.py
View File

@@ -225,7 +225,7 @@ class RidaModule(BaseMessage):
self.module_build_state = module_build_state
def publish(topic, msg, conf, service='rida'):
def publish(topic, msg, conf, service):
"""
Publish a single message to a given backend, and return
:param topic: the topic of the message (e.g. module.state.change)
@@ -238,7 +238,7 @@ def publish(topic, msg, conf, service='rida'):
handler = _messaging_backends[conf.messaging]['publish']
except KeyError:
raise KeyError("No messaging backend found for %r" % conf.messaging)
return handler(topic, msg, service=service)
return handler(topic, msg, conf, service)
def listen(conf, **kwargs):
@@ -257,7 +257,8 @@ def listen(conf, **kwargs):
yield event
def _fedmsg_publish(conf, topic, msg, service):
def _fedmsg_publish(topic, msg, conf, service):
# fedmsg doesn't really need access to conf, however other backends do
import fedmsg
return fedmsg.publish(topic, msg=msg, modname=service)
@@ -314,7 +315,7 @@ def _amq_listen(conf, **kwargs):
if msg_obj:
yield msg_obj
def _amq_publish(conf, topic, msg, service):
def _amq_publish(topic, msg, conf, service):
import proton
msngr = _amq_get_messenger(conf)
message = proton.Message()