Dump N messages into a linefeed delimited file from a queue

dump.py

import rabbitpy

MSG_COUNT = 100
FILENAME = 'messages.dump'

with rabbitpy.Connection('amqp://guest:guest@localhost:5672/%2f') as conn:
    with conn.channel() as channel:
        queue = rabbitpy.Queue(channel, 'example')
        count = 0
        with open(FILENAME, 'wb') as handle:
          for message in queue.consume_messages():
              handle.write(message.body + '\n')              
              count += 1
              if count == MSG_COUNT:
                  break