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