module LaGear::Worker

Public Class Methods

included(base) click to toggle source
# File lib/la_gear/worker.rb, line 3
def self.included(base)
  if sidekiq_proc?
    base.extend(NoOpSneakersClassMethods)
  else
    base.send(:include, ::Sneakers::Worker)
    base.extend(SneakersClassMethods)

    base.from_queue base.default_queue_name, base.default_queue_opts
  end
  base.send(:include, ::Sidekiq::Worker)
  base.extend(DefaultClassMethods)
end
sidekiq_proc?() click to toggle source
# File lib/la_gear/worker.rb, line 17
def sidekiq_proc?
  $0.end_with?('sidekiq')
end

Public Instance Methods

work(msg) click to toggle source
# File lib/la_gear/worker.rb, line 76
def work(msg)
  msg = self.class.deserialize(msg)
  self.class.perform_async(*msg.values)
  ack!
end