module Qwrapper
Qwrapper
is an idomatic API for working with message queues.
Constants
- VERSION
Attributes
config[RW]
version[R]
Public Class Methods
config=(value)
click to toggle source
# File lib/qwrapper.rb, line 21 def config=(value) @logger = value[:logger] if value.has_key?(:logger) @config = value end
connect!()
click to toggle source
# File lib/qwrapper.rb, line 30 def connect! queue.connect! if queue end
disconnect!()
click to toggle source
# File lib/qwrapper.rb, line 34 def disconnect! queue.disconnect! if queue end
queue()
click to toggle source
# File lib/qwrapper.rb, line 38 def queue @queue ||= begin base = Qwrapper::Queues::Base q = case self.config[:queue_type].to_s.to_sym when :rabbitmq then Qwrapper::Queues::RabbitMQ.new(self.config) when :"" then nil when nil then nil else raise "Unsupported queue_type '#{queue_type}'" end end end