Naive Consumer of Fedora Infra Bus

fedmsg_consume.py

#!/usr/bin/env python

# Naive consuming, courtesy: threebean
# http://fedmsg.readthedocs.org/en/latest/consuming/#naive-consuming

import fedmsg

config = fedmsg.config.load_config([], None)

# Disable that warning about not sending.  We know.  We only want to tail.
config['mute'] = True

# Disable timing out so that we can tail forever.  This is deprecated and will
# disappear in future versions.
config['timeout'] = 0

with open('messages','w') as f:
    for name, endpoint, topic, msg in fedmsg.tail_messages(**config):
        print name, topic, msg  # or use fedmsg.encoding.pretty_dumps(msg)
        f.write(name + ':' + topic + '\n')
        f.write(str(msg) + '\n')
        f.write('\n')