module SemanticLogger
def self.lag_check_interval=(lag_check_interval)
Set the check_interval which is the number of messages between checks
def self.lag_check_interval=(lag_check_interval) Logger.processor.lag_check_interval = lag_check_interval end