def queue_emission(self, msg):
if not msg:<EOL><INDENT>return<EOL><DEDENT>for _emitter in self._emit:<EOL><INDENT>if not hasattr(_emitter, '<STR_LIT>'):<EOL><INDENT>continue<EOL><DEDENT>def emit(emitter=_emitter):<EOL><INDENT>self.log.debug("<STR_LIT>".format(emitter.name))<EOL>emitter.emit(msg)<EOL><DEDENT>self.log.debug("<STR_LIT>".format(<EOL>_emitter.name, self._emit_queue.qsize()))<EOL>self._emit_queue.put(emit)<EOL><DEDENT>
queue an emission of a message for all output plugins