Module: LaGear::Worker

Defined in:
lib/la_gear/worker.rb

Defined Under Namespace

Modules: DefaultClassMethods, NoOpSneakersClassMethods, SneakersClassMethods

Class Method Summary collapse

Instance Method Summary collapse

Class Method Details

.included(base) ⇒ Object 



3
4
5
6
7
8
9
10
11
12
13
14
 
# 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? ⇒ Boolean

Returns:

  • (Boolean) 


17
18
19
 
# File 'lib/la_gear/worker.rb', line 17

def sidekiq_proc?
  $0.end_with?('sidekiq')
end

Instance Method Details

#work(msg) ⇒ Object 



76
77
78
79
80
 
# File 'lib/la_gear/worker.rb', line 76

def work(msg)
  msg = self.class.deserialize(msg)
  self.class.perform_async(*msg.values)
  ack!
end