class Requeus::Impl
Public Instance Methods
blob_sequence()
click to toggle source
# File lib/requeus/impl.rb, line 39 def blob_sequence @blob_sequence ||= config['blob']['sequence'].split.map do |name| conf = @config['blob'][name] Requeus::BlobStore.new name, conf end end
config()
click to toggle source
# File lib/requeus/impl.rb, line 20 def config @config ||= YAML.load_file(@config_path)[ENV['REQUEUS_ENV'] || ENV['RAILS_ENV'] || 'development'] end
config_path=(path)
click to toggle source
# File lib/requeus/impl.rb, line 16 def config_path= path @config_path = path end
queues()
click to toggle source
# File lib/requeus/impl.rb, line 24 def queues @queues ||= {}.tap do |queues| config['queues'].each do |name, conf| queues[name] = Requeus::Queue.new conf end end end
request(queue, method, path, params, headers, force_endpoint)
click to toggle source
# File lib/requeus/impl.rb, line 7 def request queue, method, path, params, headers, force_endpoint r = Requeus::Request.new(method, path, params, headers, force_endpoint).to_json server_sequence.any? {|q| q.put(queues[queue].name, r)} end
server_sequence()
click to toggle source
# File lib/requeus/impl.rb, line 32 def server_sequence @server_sequence ||= config['servers']['sequence'].split.map do |name| conf = @config['servers'][name] Requeus::Server.new name, conf end end
start_workers()
click to toggle source
# File lib/requeus/impl.rb, line 12 def start_workers queues.values.map {|q| q.start_workers}.flatten.each(&:join) end