Module: Quebert

Defined in:
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/async_sender/promise.rb,
lib/quebert/controller/beanstalk.rb,
lib/quebert/async_sender/instance.rb,
lib/quebert/async_sender/active_record.rb,
lib/quebert/controller/null_controller.rb

Defined Under Namespace

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

Constant Summary collapse

VERSION = 
"3.3.0"

Class Method Summary collapse

Class Method Details

.backends ⇒ Object

Registry for quebert backends



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

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

.configuration ⇒ Object Also known as: config 



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

def configuration
  @configuration ||= Configuration.new
end

.deprecate(message, &block) ⇒ Object

Deprecation notice for code within block.



36
37
38
39
 
# File 'lib/quebert.rb', line 36

def deprecate(message, &block)
  logger.warn "Quebert Deprecation Notice: #{message}"
  block.call
end

.logger ⇒ Object

Make this easier for elsewhere in the app



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

def logger
  config.logger
end

.serializers ⇒ Object 



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

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