#NEWLINE# def _get_or_create_connection( self , connection_name ) : #NEWLINE# #INDENT# if ( connection_name not in self . _connection_by_name ) : #NEWLINE# #INDENT# connection_config = self . _connection_config_by_name [ connection_name ] #NEWLINE# connection = AMQPConnection ( connection_name , ** connection_config ) #NEWLINE# connection . configure ( self . runtime_environment ) #NEWLINE# connection . setServiceParent ( self ) #NEWLINE# self . _connection_by_name [ connection_name ] = connection #NEWLINE# #UNINDENT# return self . _connection_by_name [ connection_name ]