'If we are not closing our connection to RabbitMQ, schedule another
message to be delivered in PUBLISH_INTERVAL seconds.'

def schedule_next_message(self):

    LOGGER.info('Scheduling    next    message    for    %0.1f    seconds', self.PUBLISH_INTERVAL)
    self._connection.add_timeout(self.PUBLISH_INTERVAL, self.publish_message)
