def schedule_next_message(self):
        if self.m_stopping:
            self.lg("Stopping Scheduler", 6)
            return
        else:
            self.lg("Scheduling next message for seconds(" + str(self.m_publish_interval) + ")", 6)

            self.m_cur_message                  = self.m_messages[self.m_cur_message_template]
            self.m_message_type                 = str(self.m_cur_message["MessageType"])
            self.m_number_to_send               = int(self.m_cur_message["NumberToSend"])

            self.m_connection.add_timeout(self.m_publish_interval, self.publish_message)
    # end of schedule_next_message
If we are not closing our connection to RabbitMQ, schedule another
dataset/ETHPy150Open GetLevvel/message-simulator/src/rabbit_message_publisher.py/RabbitMessagePublisher.schedule_next_message