Class: VCAP::Services::Base::SnapshotV2::SnapshotJob::QueueResolver

Inherits:
Object
  • Object
show all
Extended by:
Forwardable
Defined in:
lib/base/snapshot_v2/snapshot_job.rb

Instance Method Summary collapse

Constructor Details

#initialize(job_class) ⇒ QueueResolver

Returns a new instance of QueueResolver.



23
24
25
 
# File 'lib/base/snapshot_v2/snapshot_job.rb', line 23

def initialize(job_class)
  @job_class = job_class
end

Instance Method Details

#resolve(*args) ⇒ Object 



27
28
29
30
31
32
33
34
 
# File 'lib/base/snapshot_v2/snapshot_job.rb', line 27

def resolve(*args)
  result = nil
  args.each do |arg|
    result = arg[queue_lookup_key] if (arg.is_a? Hash) && (arg.has_key?(queue_lookup_key))
  end
  raise "no queue matched for look up key #{queue_lookup_key} and args #{args}" unless result
  result
end