class Asynchronic::QueueEngine::Synchronic
Attributes
options[R]
stubs[R]
Public Class Methods
new(options={})
click to toggle source
# File lib/asynchronic/queue_engine/synchronic.rb, line 7 def initialize(options={}) @options = options @stubs = {} end
Public Instance Methods
[](name)
click to toggle source
# File lib/asynchronic/queue_engine/synchronic.rb, line 20 def [](name) Queue.new self end
active_connections()
click to toggle source
# File lib/asynchronic/queue_engine/synchronic.rb, line 32 def active_connections [Asynchronic.connection_name] end
asynchronic?()
click to toggle source
# File lib/asynchronic/queue_engine/synchronic.rb, line 28 def asynchronic? false end
default_queue()
click to toggle source
# File lib/asynchronic/queue_engine/synchronic.rb, line 12 def default_queue Asynchronic.default_queue end
environment()
click to toggle source
# File lib/asynchronic/queue_engine/synchronic.rb, line 16 def environment @environment ||= options.fetch(:environment, Asynchronic.environment) end
stub(job, &block)
click to toggle source
# File lib/asynchronic/queue_engine/synchronic.rb, line 24 def stub(job, &block) stubs[job] = block end