Method: Pgq::Worker.connection

Defined in:
lib/pgq/worker.rb

.connection(queue) ⇒ Object 



19
20
21
22
23
24
25
26
 
# File 'lib/pgq/worker.rb', line 19

def self.connection(queue)
  klass = predict_queue_class(queue)
  if klass
    klass.connection
  else
    raise "can't find klass for queue #{queue}"
  end
end