msg.rb

def msg(str)
  @state ||= Concurrent::Map.new

  if @last_msg && (Time.now - @last_msg) < 1
    @state[:str] = str

    task = @state[:scheduled_task]
    if !task || !task.pending?
      @state[:scheduled_task] = Concurrent::ScheduledTask.execute(1) do
        update_db_with_msg(@state[:str])
      end
    end

  else
    update_db_with_msg(str)
  end

  @last_msg = Time.now
end