#setup queue
connection = pika.BlockingConnection(pika.ConnectionParameters(host='0.0.0.0'))
channel = connection.channel()

print("connection: " + str(connection))

from twit.models.twitter import Tweet
import time

def consume_callback(ch, method, properties, body):
    print(" [x] Received %r" % (body,))
    # tasks.store_tweet.delay(body.text, body.created_at, body.screen_name)

    t = Tweet()
    t.text = body.text
    t.created_at = body.created_at
    t.screen_name = body.screen_name
    DBSession.add(t)

    print " [x] Done"
    ch.basic_ack(delivery_tag = method.delivery_tag)

channel.basic_qos(prefetch_count=1)
channel.basic_consume(consume_callback,
                      queue='twitter_topic_feed')

channel.start_consuming()


LOG:

2014-05-31 11:35:46,338 INFO  [pika.adapters.base_connection][MainThread] Connecting to 0.0.0.0:5672
connection: <pika.adapters.blocking_connection.BlockingConnection object at 0x10b54aa90>
 [x] Received '{"text": "@CMPunkisBITW @ddlovato the car is a whale? Okay then...", "created_at": 1401564953.0, "screen_name": "BeautifulDemiD"}'
Traceback (most recent call last):
  File "../bin/pserve", line 9, in <module>
    load_entry_point('pyramid==1.5', 'console_scripts', 'pserve')()
  File "/Users/Shared/webapp/twit_env/lib/python2.7/site-packages/pyramid-1.5-py2.7.egg/pyramid/scripts/pserve.py", line 51, in main
    return command.run()
  File "/Users/Shared/webapp/twit_env/lib/python2.7/site-packages/pyramid-1.5-py2.7.egg/pyramid/scripts/pserve.py", line 316, in run
    global_conf=vars)
  File "/Users/Shared/webapp/twit_env/lib/python2.7/site-packages/pyramid-1.5-py2.7.egg/pyramid/scripts/pserve.py", line 340, in loadapp
    return loadapp(app_spec, name=name, relative_to=relative_to, **kw)
  File "/Users/Shared/webapp/twit_env/lib/python2.7/site-packages/PasteDeploy-1.5.2-py2.7.egg/paste/deploy/loadwsgi.py", line 247, in loadapp
    return loadobj(APP, uri, name=name, **kw)
  File "/Users/Shared/webapp/twit_env/lib/python2.7/site-packages/PasteDeploy-1.5.2-py2.7.egg/paste/deploy/loadwsgi.py", line 272, in loadobj
    return context.create()
  File "/Users/Shared/webapp/twit_env/lib/python2.7/site-packages/PasteDeploy-1.5.2-py2.7.egg/paste/deploy/loadwsgi.py", line 710, in create
    return self.object_type.invoke(self)
  File "/Users/Shared/webapp/twit_env/lib/python2.7/site-packages/PasteDeploy-1.5.2-py2.7.egg/paste/deploy/loadwsgi.py", line 146, in invoke
    return fix_call(context.object, context.global_conf, **context.local_conf)
  File "/Users/Shared/webapp/twit_env/lib/python2.7/site-packages/PasteDeploy-1.5.2-py2.7.egg/paste/deploy/util.py", line 55, in fix_call
    val = callable(*args, **kw)
  File "/Users/Shared/webapp/twit_env/twit/twit/__init__.py", line 61, in main
    config.scan("twit.views")
  File "/Users/Shared/webapp/twit_env/lib/python2.7/site-packages/pyramid-1.5-py2.7.egg/pyramid/config/__init__.py", line 929, in scan
    ignore=ignore)
  File "/Users/Shared/webapp/twit_env/lib/python2.7/site-packages/venusian-1.0a8-py2.7.egg/venusian/__init__.py", line 199, in scan
    __import__(modname)
  File "/Users/Shared/webapp/twit_env/twit/twit/views/api.py", line 710, in <module>
    channel.start_consuming()
  File "/Users/Shared/webapp/twit_env/lib/python2.7/site-packages/pika/adapters/blocking_connection.py", line 917, in start_consuming
    self.connection.process_data_events()
  File "/Users/Shared/webapp/twit_env/lib/python2.7/site-packages/pika/adapters/blocking_connection.py", line 218, in process_data_events
    raise exceptions.ConnectionClosed()
pika.exceptions.ConnectionClosed