Sha256: e378a9894b26881f8b705cf3134b99151559e2d70f27fdab0f6193f63c44906e

Contents?: true

Size: 1.24 KB

Versions: 9

Compression:

Stored size: 1.24 KB

Contents

require 'quebert/version'

module Quebert
  autoload :Logging,            'quebert/logging'
  autoload :Serializer,         'quebert/serializer'
  autoload :Configuration,      'quebert/configuration'
  autoload :Timeout,            'quebert/timeout'
  autoload :Job,                'quebert/job'
  autoload :Controller,         'quebert/controller'
  autoload :Backend,            'quebert/backend'
  autoload :Support,            'quebert/support'
  autoload :Worker,             'quebert/worker'
  autoload :CommandLineRunner,  'quebert/command_line_runner'
  autoload :AsyncSender,        'quebert/async_sender'

  class << self
    def configuration
      @configuration ||= Configuration.new
    end
    alias_method :config, :configuration

    # Registry for quebert backends
    def backends
      @backends ||= Support::Registry.new
    end
    
    def serializers
      @serializers ||= Support::ClassRegistry.new
    end
    
    # Make this easier for elsewhere in the app
    def logger
      config.logger
    end
  end
  
  # Register built-in Quebert backends
  Quebert.backends.register :beanstalk,       Backend::Beanstalk
  Quebert.backends.register :in_process,      Backend::InProcess
  Quebert.backends.register :sync,            Backend::Sync
end

Version data entries

9 entries across 9 versions & 1 rubygems

Version Path
quebert-1.12.0 lib/quebert.rb
quebert-1.11.0 lib/quebert.rb
quebert-1.0.9 lib/quebert.rb
quebert-1.0.8 lib/quebert.rb
quebert-1.0.7 lib/quebert.rb
quebert-1.0.6 lib/quebert.rb
quebert-1.0.5 lib/quebert.rb
quebert-1.0.4 lib/quebert.rb
quebert-1.0.2 lib/quebert.rb