Sha256: faab49f82942f67548aaa22ad97c130a4c29662193c9d09e8eb4171e0b799e26
Contents?: true
Size: 842 Bytes
Versions: 47
Compression:
Stored size: 842 Bytes
Contents
require 'qu/version'
require 'qu/logger'
require 'qu/failure'
require 'qu/payload'
require 'qu/backend/base'
require 'forwardable'
require 'logger'
module Qu
autoload :Worker, 'qu/worker'
extend SingleForwardable
extend self
attr_accessor :backend, :failure, :logger
def_delegators :backend, :length, :queues, :reserve, :clear, :connection=
def backend
@backend || raise("Qu backend not configured. Install one of the backend gems like qu-redis.")
end
def configure(&block)
block.call(self)
end
def enqueue(klass, *args)
backend.enqueue Payload.new(:klass => klass, :args => args)
end
end
Qu.configure do |c|
c.logger = Logger.new(STDOUT)
c.logger.level = Logger::INFO
end
if defined?(Rails)
if defined?(Rails::Railtie)
require 'qu/railtie'
else
Qu.logger = Rails.logger
end
end
Version data entries
47 entries across 47 versions & 2 rubygems