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