modules/fm-orchestrator
1
0
Fork 0
mirror of https://pagure.io/fm-orchestrator.git synced 2026-02-12 17:44:59 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

pass the entire message to get_abstracted_msg()

Browse Source 
Other messaging backends may use different formats, so pass the
entire message through and let get_abstracted_msg() handle it.
This commit is contained in:
Mike Bonnet
2017-09-15 22:58:09 +00:00
committed by Ralph Bean
parent 2a3aea9c97
commit 1f077a12ea
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
module_build_service/scheduler/consumer.py
View File

@@ -131,7 +131,7 @@ class MBSConsumer(fedmsg.consumers.FedmsgConsumer):
if isinstance(message, module_build_service.messaging.BaseMessage):
msg = message
else:
msg = self.get_abstracted_msg(message['body'])
msg = self.get_abstracted_msg(message)
# Primary work is done here.
try:
@@ -147,10 +147,10 @@ class MBSConsumer(fedmsg.consumers.FedmsgConsumer):
# Convert the message to an abstracted message
if conf.messaging == 'fedmsg':
msg = module_build_service.messaging.BaseMessage.from_fedmsg(
message['topic'], message)
message['body']['topic'], message['body'])
elif conf.messaging == 'amq':
msg = module_build_service.messaging.BaseMessage.from_amq(
message['topic'], message)
message['body']['topic'], message['body'])
else:
raise ValueError('The messaging format "{0}" is not supported'
.format(conf.messaging))