Class: Mantle::Workers::ProcessWorker

Inherits:

Object

• Object
• Mantle::Workers::ProcessWorker

Includes:

Sidekiq::Worker

Defined in:

lib/mantle/workers/process_worker.rb

Instance Method Summary

• #perform(channel, message) ⇒ Object

Instance Method Details

#perform(channel, message) ⇒ Object

# 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