def check_if_done(self):
        
        if self.m_num_amqp_msgs == int(self.m_acked) + int(self.m_nacked):

            if self.m_run_summary:
                lg("Done Waiting for Messages(" + str(self.m_num_amqp_msgs) + ")", 6)
                self.run_summary()
            else:
                lg("", 6)

            self.stop()
        else:
        
            if not self.m_stopping:
                if self.m_debug:
                    lg("Not Done Waiting(" + str(self.m_num_amqp_msgs) + ") Sent(" + str(self.m_message_number) + ") Total(" + str(len(self.m_sent_messages)) + ")", 6)
                self.m_connection.add_timeout(self.m_wait_interval, self.check_if_done)
    # end of check_if_done
dataset/ETHPy150Open GetLevvel/message-simulator/src/rabbit_message_publisher.py/RabbitMessagePublisher.check_if_done/original