plugin_init.rb

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