#NEWLINE# def collect_results( self , data_values ) : #NEWLINE# #INDENT# 'Receive the data from the consumers polled and process it.\n\n        :param dict data_values: The poll data returned from the consumer\n        :type data_values: dict\n\n        ' #NEWLINE# self . last_poll_results [ 'timestamp' ] = self . poll_data [ 'timestamp' ] #NEWLINE# consumer_name = data_values [ 'consumer_name' ] #NEWLINE# del data_values [ 'consumer_name' ] #NEWLINE# process_name = data_values [ 'name' ] #NEWLINE# del data_values [ 'name' ] #NEWLINE# if ( consumer_name not in self . last_poll_results ) : #NEWLINE# #INDENT# self . last_poll_results [ consumer_name ] = dict ( ) #NEWLINE# #UNINDENT# self . last_poll_results [ consumer_name ] [ process_name ] = data_values #NEWLINE# self . stats = self . calculate_stats ( self . last_poll_results )