Class: AdvancedSneakersActiveJob::WorkersRegistry

Inherits:
Object
  • Object
show all
Defined in:
lib/advanced_sneakers_activejob/workers_registry.rb

Overview

Sneakers uses Sneakers::Worker::Classes array to track all workers. WorkersRegistry mocks original array to track ActiveJob workers separately.

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ WorkersRegistry

Returns a new instance of WorkersRegistry.



13
14
15
16
 
# File 'lib/advanced_sneakers_activejob/workers_registry.rb', line 13

def initialize
  @sneakers_workers = []
  @activejob_workers = []
end

Dynamic Method Handling

This class handles dynamic methods through the method_missing method

#method_missing(method_name, *args, &block) ⇒ Object 



57
58
59
60
61
62
63
 
# File 'lib/advanced_sneakers_activejob/workers_registry.rb', line 57

def method_missing(method_name, *args, &block)
  if call.respond_to?(method_name)
    call.send(method_name, *args, &block)
  else
    super
  end
end

Instance Attribute Details

#sneakers_workers ⇒ Object (readonly)

Returns the value of attribute sneakers_workers.



7
8
9
 
# File 'lib/advanced_sneakers_activejob/workers_registry.rb', line 7

def sneakers_workers
  @sneakers_workers
end

Instance Method Details

#<<(worker) ⇒ Object 



18
19
20
21
22
23
24
 
# File 'lib/advanced_sneakers_activejob/workers_registry.rb', line 18

def <<(worker)
  if worker <= ActiveJob::QueueAdapters::AdvancedSneakersAdapter::JobWrapper
    @activejob_workers << worker
  else
    sneakers_workers << worker
  end
end

#activejob_workers ⇒ Object 



51
52
53
54
55
 
# File 'lib/advanced_sneakers_activejob/workers_registry.rb', line 51

def activejob_workers
  define_active_job_consumers

  @activejob_workers
end

#call ⇒ Object

Sneakers workergroup supports callable objects. github.com/jondot/sneakers/pull/210/files github.com/jondot/sneakers/blob/7a972d22a58de8a261a738d9a1e5fb51f9608ede/lib/sneakers/workergroup.rb#L28



29
30
31
32
33
34
35
36
37
 
# File 'lib/advanced_sneakers_activejob/workers_registry.rb', line 29

def call
  case activejob_workers_strategy
  when :only    then activejob_workers
  when :exclude then sneakers_workers
  when :include then sneakers_workers + activejob_workers
  else
    raise "Unknown activejob_workers_strategy '#{activejob_workers_strategy}'"
  end
end

#define_active_job_consumers ⇒ Object 



69
70
71
72
73
 
# File 'lib/advanced_sneakers_activejob/workers_registry.rb', line 69

def define_active_job_consumers
  active_job_classes_with_matching_adapter.each do |worker|
    AdvancedSneakersActiveJob.define_consumer(queue_name: worker.new.queue_name)
  end
end

#respond_to_missing?(method_name, include_private = false) ⇒ Boolean

Returns:

  • (Boolean) 


65
66
67
 
# File 'lib/advanced_sneakers_activejob/workers_registry.rb', line 65

def respond_to_missing?(method_name, include_private = false)
  call.respond_to?(method_name) || super
end

#to_hash ⇒ Object Also known as: to_h, inspect 



39
40
41
42
43
44
 
# File 'lib/advanced_sneakers_activejob/workers_registry.rb', line 39

def to_hash
  {
    sneakers_workers: sneakers_workers,
    activejob_workers: activejob_workers
  }
end