plugin_init.rb

RealtimeIndexing.class_eval do
  def self.disable(&block)
    Thread.current[:realtime_indexing_disabled] = true
    block.call
#    Thread.current[:realtime_indexing_disabled] = false
  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