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