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

Improved conditions for message filtering

Browse Source
This commit is contained in:
Lubos Kocman
2016-09-26 15:24:43 +02:00
parent 9783fe6c04
commit 11703ccb41
1 changed files with 8 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
rida/messaging.py
View File

@@ -57,15 +57,16 @@ class BaseMessage(object):
@staticmethod
def from_amq(topic, msg):
msg_obj = None
properties = None
body = None
if hasattr(msg, 'properties'):
properties = json.loads(msg.properties, encoding='utf8')
if not ((properties.get('service') == 'koji' or properties.get('service') == 'rida')):
log.debug("Skipping msg: %s" % msg)
return None
if not hasattr(msg, 'properties'):
return None # Unrelated message not identifying service origin
properties = json.loads(msg.properties, encoding='utf8')
service = properties.get('service')
if service not in ('koji', 'rida'):
log.debug('Skipping msg due service=%s which is not related (msg=%r): ' % (service, msg))
return None
# This probably appies only for brew
# Also wouldn't be easier to use properties?
if service == 'koji':