module Message::Q

Public Instance Methods

adapter() click to toggle source
# File lib/message/q.rb, line 16
def adapter
  @adapter ||= :in_memory
end
adapter=(name) click to toggle source
# File lib/message/q.rb, line 20
def adapter=(name)
  if name.nil?
    @adapter = nil
    return
  end
  name = name.to_sym
  unless adapters.has_key?(name)
    raise AdapterNotFoundError, "Could not find adapter named #{name.inspect}"
  end
  @adapter = name
end
adapters() click to toggle source
# File lib/message/q.rb, line 12
def adapters
  @adapters ||= { :in_memory => InMemoryQueue }
end
init(name) click to toggle source
# File lib/message/q.rb, line 8
def init(name)
  adapters[adapter].new(name)
end
reset() click to toggle source
# File lib/message/q.rb, line 32
def reset
  @adapter = nil
  @adapters = nil
end