def process_rule_info(self):
while True:<EOL><INDENT>try:<EOL><INDENT>event = self._iptq.get(block=False)<EOL>LOG.debug('<STR_LIT>', event)<EOL>self.update_rule_entry(event)<EOL><DEDENT>except queue.Empty:<EOL><INDENT>self.update_iptables()<EOL>time.sleep(<NUM_LIT:1>)<EOL><DEDENT>except Exception:<EOL><INDENT>LOG.exception('<STR_LIT>')<EOL><DEDENT><DEDENT>
Task responsible for processing event queue.