Method: Mantle::Workers::ProcessWorker#perform

Defined in:
lib/mantle/workers/process_worker.rb

#perform(channel, message) ⇒ Object 



8
9
10
11
12
 
# File 'lib/mantle/workers/process_worker.rb', line 8

def perform(channel, message)
  Mantle.receive_message(channel, message)
  Mantle::LocalRedis.set_message_successfully_received
  Mantle::CatchUp.new.enqueue_clear_if_ready
end