Module: Qsagi::Queue::ClassMethods
- Defined in:
- lib/qsagi/queue.rb
Instance Method Summary collapse
- #_exchange ⇒ Object
- #_exchange_options ⇒ Object
- #_message_class ⇒ Object
- #_queue(options) ⇒ Object
- #_serializer ⇒ Object
- #connect(opts = {}, &block) ⇒ Object
- #default_options ⇒ Object
- #exchange(exchange, options = {}) ⇒ Object
- #message_class(message_class) ⇒ Object
- #serializer(serializer) ⇒ Object
Instance Method Details
#_exchange ⇒ Object
61 62 63 |
# File 'lib/qsagi/queue.rb', line 61 def _exchange @exchange || "" end |
#_exchange_options ⇒ Object
65 66 67 |
# File 'lib/qsagi/queue.rb', line 65 def @exchange_options || {} end |
#_message_class ⇒ Object
69 70 71 |
# File 'lib/qsagi/queue.rb', line 69 def @message_class || Qsagi::Message end |
#_queue(options) ⇒ Object
21 22 23 24 25 26 27 28 |
# File 'lib/qsagi/queue.rb', line 21 def _queue() standard_queue = StandardQueue.new() if [:queue_type] == :confirmed ConfirmedQueue.new(standard_queue) else standard_queue end end |
#_serializer ⇒ Object
73 74 75 |
# File 'lib/qsagi/queue.rb', line 73 def _serializer @serializer || Qsagi::DefaultSerializer end |
#connect(opts = {}, &block) ⇒ Object
8 9 10 11 12 13 14 15 16 17 18 19 |
# File 'lib/qsagi/queue.rb', line 8 def connect(opts={}, &block) = .merge(opts) queue = _queue() begin queue.connect block.call(queue) ensure queue.disconnect end end |
#default_options ⇒ Object
30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 |
# File 'lib/qsagi/queue.rb', line 30 def { :host => host, :port => port, :queue_type => :standard, :heartbeat => heartbeat, :message_class => , :queue_name => queue_name, :durable => true, :queue_arguments => {"x-ha-policy" => "all"}, :persistent => true, :mandatory => true, :serializer => _serializer, :exchange_options => , :exchange => _exchange } end |
#exchange(exchange, options = {}) ⇒ Object
48 49 50 51 |
# File 'lib/qsagi/queue.rb', line 48 def exchange(exchange, = {}) @exchange = exchange @exchange_options = {:type => :direct}.merge() end |
#message_class(message_class) ⇒ Object
53 54 55 |
# File 'lib/qsagi/queue.rb', line 53 def () @message_class = end |
#serializer(serializer) ⇒ Object
57 58 59 |
# File 'lib/qsagi/queue.rb', line 57 def serializer(serializer) @serializer = serializer end |