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