#NEWLINE# def load_domain_config( self , loaded_config ) : #NEWLINE# #INDENT# '\n        Loads the domain_config and sets up queue_dict\n        @param loaded_config: the yaml loaded config dict from zookeeper\n        ' #NEWLINE# self . domain_config = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } #NEWLINE# if ( loaded_config and ( 'domains' in loaded_config ) ) : #NEWLINE# #INDENT# for domain in loaded_config [ 'domains' ] : #NEWLINE# #INDENT# item = loaded_config [ 'domains' ] [ loaded_config ] #NEWLINE# if ( ( 'window' in item ) and ( 'hits' in item ) ) : #NEWLINE# #INDENT# self . logger . debug ( 'Added domain {dom} to loaded config' . format ( dom = domain ) ) #NEWLINE# self . domain_config [ domain ] = item #NEWLINE# #UNINDENT# #UNINDENT# #UNINDENT# self . config_flag = True