Module: Qwrapper

Extended by:
Loggable
Defined in:
lib/qwrapper.rb,
lib/qwrapper/message.rb,
lib/qwrapper/version.rb,
lib/qwrapper/queues/base.rb,
lib/qwrapper/support/config.rb,
lib/qwrapper/queues/rabbitmq.rb,
lib/qwrapper/support/loggable.rb

Overview

Qwrapper is an idomatic API for working with message queues.

Defined Under Namespace

Modules: Loggable, Queues Classes: Config, Message, RequeueError

Constant Summary collapse

VERSION = 
"0.0.8"

Class Attribute Summary collapse

Class Method Summary collapse

Methods included from Loggable

logger, logger=

Class Attribute Details

.config ⇒ Object

Returns the value of attribute config.



14
15
16
 
# File 'lib/qwrapper.rb', line 14

def config
  @config
end

.version ⇒ String (readonly)

Returns Qwrapper version.

Returns:

  • (String) —

    Qwrapper version



17
18
19
 
# File 'lib/qwrapper.rb', line 17

def version
  @version
end

Class Method Details

.connect! ⇒ Object 



29
30
31
 
# File 'lib/qwrapper.rb', line 29

def connect!
  queue.connect! if queue
end

.disconnect! ⇒ Object 



33
34
35
 
# File 'lib/qwrapper.rb', line 33

def disconnect!
  queue.disconnect! if queue
end

.queue ⇒ Object 



37
38
39
40
41
42
43
44
45
46
47
48
 
# File 'lib/qwrapper.rb', line 37

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