#NEWLINE# def configure( self , runtime_environment ) : #NEWLINE# #INDENT# self . setServiceParent ( runtime_environment . application ) #NEWLINE# connection_configs = runtime_environment . get_configuration_value ( 'amqp.connections' , dict ( ) ) #NEWLINE# for ( connection_name , connection_config ) in connection_configs . items ( ) : #NEWLINE# #INDENT# consumers = connection_config . get ( 'basic_consumers' , dict ( ) ) #NEWLINE# for ( consumer_name , consumer_config ) in consumers . items ( ) : #NEWLINE# #INDENT# consumer = AMQPConsumer ( name = consumer_name , connection = connection_name , ** consumer_config ) #NEWLINE# consumer . configure ( runtime_environment ) #NEWLINE# consumer . setServiceParent ( self ) #NEWLINE# self . _consumer_by_name [ consumer_name ] = consumer