@@ -0,0 +1,833 @@
+import pika, json%0Afrom twitter_interface.message_parser import message_parser as message_parser%0A%0Aqueue_connection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))%0Arabbit_channel = queue_connection.channel()%0A%0Adef callback(ch, method, properties, body):%0A    print 'consumer'%0A    body = json.loads(body)%0A    %0A    isCoors = message_parser(body)%0A    if isCoors.contains('text', %5B'coors', 'coors lite', 'coors light'%5D):%0A        print body%0A    elif isCoors.contains('text', %5B'beer', 'drink', 'bar'%5D):%0A        print 'BEER PLUS: ' +body%5B'text'%5D%0A    else:%0A        print 'NOT COORS: ' + body%5B'text'%5D%0A    if body%5B'coordinates'%5D != None:%0A        print body%5B'coordinates'%5D%0A        raw_input()%0A    %0A    ch.basic_ack(delivery_tag = method.delivery_tag)%0A        %0A        %0Arabbit_channel.basic_consume(callback, queue = 'raw_twitter')

add a consumer example