plugin_init.rb

RealtimeIndexing.class_eval do
  def self.disable(&block)
    begin
      Thread.current[:realtime_indexing_disabled] = true
      block.call
    ensure
      DB.after_commit do
        Thread.current[:realtime_indexing_disabled] = false
      end
    end
  end


  def self.record_update(target, uri)
    unless Thread.current[:realtime_indexing_disabled]
      longpolling.record_update(:record => target, :uri => uri)
    end
  end


  def self.record_delete(uri)
    unless Thread.current[:realtime_indexing_disabled]
      longpolling.record_update(:record => :deleted, :uri => uri)
    end
  end
end