# -*- coding: utf-8 -*-

"""  """

import pika

def callback(ch, method, properties, body):
    print " [x] Received %r" % (body,)


def main():
    
    
    connection = pika.BlockingConnection(pika.ConnectionParameters(
            host='localhost'))
    channel = connection.channel()
    
    channel.queue_declare(queue='mabo')

    print ' [*] Waiting for messages. To exit press CTRL+C'


    channel.basic_consume(callback,
                          queue='mabo',
                          no_ack=True)

    channel.start_consuming()
    
if __name__ == '__main__':
    main()        