def check_process_counts(self):
        """Check for the minimum consumer process levels and start up new
        processes needed.

        """
        LOGGER.debug('Checking minimum consumer process levels')
        for name in self.consumers:
            processes_needed = self.process_spawn_qty(name)
            if processes_needed:
                LOGGER.info('Need to spawn %i processes for %s',
                            processes_needed, name)
                self.start_processes(name, processes_needed)
Check for the minimum consumer process levels and start up new
        processes needed.