def run(self):
global _global_kill<EOL>for message in self._messages:<EOL><INDENT>batch_file = self._getBatchFile(message)<EOL>message_contents = batch_file.getMessage(message)<EOL>self._logger.debug(<EOL>'<STR_LIT>'<EOL>.format(message))<EOL>put_succeeded = False<EOL>while not put_succeeded:<EOL><INDENT>if _global_kill.isSet():<EOL><INDENT>return<EOL><DEDENT>try:<EOL><INDENT>self._queue.put(message_contents, block=True, timeout=<NUM_LIT:1.0>)<EOL><DEDENT>except Full:<EOL><INDENT>pass<EOL><DEDENT>else:<EOL><INDENT>put_succeeded = True<EOL>self._logger.debug('<STR_LIT>')<EOL><DEDENT><DEDENT><DEDENT>
Overrides :meth:`python:threading.Thread.run`.