def run_queues(self):
if self.exception:<EOL><INDENT>raise self.exception<EOL><DEDENT>listeners = self.__listeners_for_thread<EOL>return sum(l.process() for l in listeners) > <NUM_LIT:0><EOL>
Run all queues that have data queued