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

remove unuseful/obsolete get_amq_addr call

Browse Source
This commit is contained in:
Lubos Kocman
2016-10-04 14:09:13 +02:00
parent b090a8d7f8
commit bb1110758e
1 changed files with 1 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
rida/messaging.py
View File

@@ -314,17 +314,13 @@ def _amq_listen(conf, **kwargs):
if msg_obj:
yield msg_obj
def _amq_get_dst_address(conf, topic, msg, service):
return conf.amq_broker_dest_url
def _amq_publish(conf, topic, msg, service):
import proton
mng = _amq_get_messenger(conf)
message = proton.Message()
message.address = _amq_get_dst_address(conf, topic, msg, service)
message.address = conf.amq_dest_address
message.subject = topic
message.properties['service'] = service
message.address = conf.amq_dest_address
message.content = json.dumps(msg, ensure_ascii=False).encode('utf8')
mng.put(message)
mng.send()