#NEWLINE# def register_provider( self , provider ) : #NEWLINE# #INDENT# self . provider = provider #NEWLINE# self . serializer = provider . container . config . get ( SERIALIZER_CONFIG_KEY , DEFAULT_SERIALIZER ) #NEWLINE# self . accept = [ self . serializer ] #NEWLINE# amqp_uri = provider . container . config [ AMQP_URI_CONFIG_KEY ] #NEWLINE# verify_amqp_uri ( amqp_uri ) #NEWLINE# self . connection = Connection ( amqp_uri ) #NEWLINE# self . queue = provider . queue #NEWLINE# self . _setup_consumer ( )