Method: Writefully::Process#process_message

Defined in:
lib/writefully/process.rb

#process_message ⇒ Object 



77
78
79
80
81
82
83
 
# File 'lib/writefully/process.rb', line 77

def process_message
  Proc.new do |modified, added, removed|
    queue_jobs(Indices.build_from(modified), :write)
    queue_jobs(Indices.build_from(added),    :write)
    queue_jobs(Indices.build_from(removed),  :remove)
  end
end