#NEWLINE# def check_process_counts( self ) : #NEWLINE# #INDENT# 'Check for the minimum consumer process levels and start up new\n        processes needed.\n\n        ' #NEWLINE# LOGGER . debug ( 'Checking minimum consumer process levels' ) #NEWLINE# for name in self . consumers : #NEWLINE# #INDENT# for connection in connection . consumers [ name ] . connections : #NEWLINE# #INDENT# processes_needed = self . process_spawn_qty ( name , connection ) #NEWLINE# LOGGER . debug ( 'Need to spawn %i processes for %s on %s' , processes_needed , name , connection ) #NEWLINE# if processes_needed : #NEWLINE# #INDENT# self . start_processes ( name , connection , processes_needed )