Module: Quebert

Defined in:
lib/quebert/timeout.rb,
lib/quebert.rb,
lib/quebert/job.rb,
lib/quebert/worker.rb,
lib/quebert/backend.rb,
lib/quebert/logging.rb,
lib/quebert/support.rb,
lib/quebert/version.rb,
lib/quebert/controller.rb,
lib/quebert/serializer.rb,
lib/quebert/async_sender.rb,
lib/quebert/backend/sync.rb,
lib/quebert/configuration.rb,
lib/quebert/controller/base.rb,
lib/quebert/support/pid_file.rb,
lib/quebert/support/registry.rb,
lib/quebert/backend/beanstalk.rb,
lib/quebert/async_sender/class.rb,
lib/quebert/backend/in_process.rb,
lib/quebert/async_sender/object.rb,
lib/quebert/command_line_runner.rb,
lib/quebert/controller/beanstalk.rb,
lib/quebert/async_sender/instance.rb,
lib/quebert/async_sender/active_record.rb

Overview

Setup a namespaced Quebert::Timeout class that will deal with responsible folks in 1.8.7 who use the SystemTimer gem.

Defined Under Namespace

Modules: AsyncSender, Backend, Controller, Logging, Serializer, Support Classes: CommandLineRunner, Configuration, Job, Worker

Constant Summary collapse

Timeout = 
begin
  require 'system_timer'
  ::SystemTimer
rescue LoadError
  # Install the system_timer gem if you're running this in Ruby 1.8.7!
  require 'timeout'
  ::Timeout
end
VERSION = 
"1.0.2"

Class Method Summary collapse

Class Method Details

.backends ⇒ Object

Registry for quebert backends



23
24
25
 
# File 'lib/quebert.rb', line 23

def backends
  @backends ||= Support::Registry.new
end

.configuration ⇒ Object Also known as: config 



17
18
19
 
# File 'lib/quebert.rb', line 17

def configuration
  @configuration ||= Configuration.new
end

.logger ⇒ Object

Make this easier for elsewhere in the app



32
33
34
 
# File 'lib/quebert.rb', line 32

def logger
  config.logger
end

.serializers ⇒ Object 



27
28
29
 
# File 'lib/quebert.rb', line 27

def serializers
  @serializers ||= Support::ClassRegistry.new
end