Sha256: cf70d270cf428d42bb3e3e059c023d57b5f58ad68765c767432219706dc2eefd
Contents?: true
Size: 672 Bytes
Versions: 35
Compression:
Stored size: 672 Bytes
Contents
require 'routemaster/config'
module Routemaster
module Jobs
class Client
extend Forwardable
def_delegators :@backend, :enqueue
def initialize(adapter = nil)
@backend = build_backend(adapter)
end
private
def build_backend(adapter)
case Config.queue_adapter
when :resque
require 'routemaster/jobs/backends/resque'
Backends::Resque.new(adapter)
when :sidekiq
require 'routemaster/jobs/backends/sidekiq'
Backends::Sidekiq.new(adapter)
else
raise "Unsupported queue adapter '#{Config.queue_adapter}"
end
end
end
end
end
Version data entries
35 entries across 35 versions & 1 rubygems