#NEWLINE# def create_README_consumer( amqpconn ) : #NEWLINE# #INDENT# from carrot.messaging import Consumer #NEWLINE# consumer = Consumer ( connection = amqpconn , queue = README_QUEUE , exchange = README_EXCHANGE , routing_key = README_ROUTING_KEY ) #NEWLINE# tcallbacks = CallbacksTestable ( ) #NEWLINE# consumer . register_callback ( tcallbacks . import_feed ) #NEWLINE# consumer . register_callback ( tcallbacks . dump_message ) #NEWLINE# return ( amqpconn , tcallbacks )