code: def process_rule_info(self):
          
  
          while True:
              try:
                  event = self._iptq.get(block=False)
                  LOG.debug('Dequeue event: %s.', event)
                  self.update_rule_entry(event)
              except queue.Empty:
                  self.update_iptables()
                  time.sleep(1)
              except Exception:
                  LOG.exception('ERROR: failed to process queue')
docs: Task responsible for processing event queue.