Class: Howler::Worker

Inherits:
Object
  • Object
show all
Includes:
Celluloid
Defined in:
lib/howler/worker.rb

Instance Method Summary collapse

Instance Method Details

#perform(message, queue) ⇒ Object



7
8
9
10
11
12
13
14
15
# File 'lib/howler/worker.rb', line 7

def perform(message, queue)
  queue = Howler::Queue.new(queue) unless queue.is_a?(Howler::Queue)

  queue.statistics(message.klass, message.method, message.args) do
    message.klass.new.send(message.method, *message.args)
  end

  Howler::Manager.current.done_chewing(current_actor)
end