def process_amqp_msgs(self):
LOG.info('<STR_LIT>')<EOL>while True:<EOL><INDENT>(mtd_fr, hdr_fr, body) = (None, None, None)<EOL>try:<EOL><INDENT>if self.consume_channel:<EOL><INDENT>(mtd_fr, hdr_fr, body) = self.consume_channel.basic_get(<EOL>self._dcnm_queue_name)<EOL><DEDENT>if mtd_fr:<EOL><INDENT>LOG.info('<STR_LIT>', body)<EOL>self._cb_dcnm_msg(mtd_fr, body)<EOL>self.consume_channel.basic_ack(mtd_fr.delivery_tag)<EOL><DEDENT>else:<EOL><INDENT>try:<EOL><INDENT>self._conn.sleep(<NUM_LIT:1>)<EOL><DEDENT>except AttributeError:<EOL><INDENT>time.sleep(<NUM_LIT:1>)<EOL><DEDENT><DEDENT><DEDENT>except Exception:<EOL><INDENT>exc_type, exc_value, exc_tb = sys.exc_info()<EOL>tb_str = traceback.format_exception(exc_type,<EOL>exc_value, exc_tb)<EOL>LOG.exception("<STR_LIT>"<EOL>"<STR_LIT>", {<EOL>'<STR_LIT>': self._dcnm_queue_name,<EOL>'<STR_LIT>': exc_type,<EOL>'<STR_LIT>': exc_value,<EOL>'<STR_LIT>': tb_str})<EOL><DEDENT><DEDENT>
Process AMQP queue messages.

        It connects to AMQP server and calls callbacks to process DCNM events,
        i.e. routing key containing '.cisco.dcnm.', once they arrive in the
        queue.