Class: JobQueue::BeanstalkAdapter::BeanstalkPoolFix

Inherits:
Beanstalk::Pool
  • Object
show all
Defined in:
lib/job_queue/adapters/beanstalk_adapter.rb

Instance Method Summary collapse

Instance Method Details

#job_stats(id) ⇒ Object 



91
92
93
 
# File 'lib/job_queue/adapters/beanstalk_adapter.rb', line 91

def job_stats(id)
  make_hash(send_to_all_conns(:job_stats, id))
end

#put_and_report_conn(body, pri = 65536, delay = 0, ttr = 120) ⇒ Object 



79
80
81
 
# File 'lib/job_queue/adapters/beanstalk_adapter.rb', line 79

def put_and_report_conn(body, pri=65536, delay=0, ttr=120)
  send_to_rand_conn_and_report(:put, body, pri, delay, ttr)
end

#send_to_rand_conn_and_report(*args) ⇒ Object 



83
84
85
86
87
88
89
 
# File 'lib/job_queue/adapters/beanstalk_adapter.rb', line 83

def send_to_rand_conn_and_report(*args)
  connect()
  retry_wrap{
    conn = pick_connection
    {:host => conn.addr, :id => call_wrap(conn, *args)}
  }
end