class EventMachine::Synchrony::AMQP::Queue

Public Class Methods

new(*params) click to toggle source
Calls superclass method
# File lib/em-synchrony/amqp.rb, line 149
def initialize(*params)
  f = Fiber.current
  super(*params, &EM::Synchrony::AMQP.sync_cb(f))
  queue, declare_ok = Fiber.yield
  raise Error.new unless declare_ok.is_a?(::AMQ::Protocol::Queue::DeclareOk)
  queue
end

Public Instance Methods

asubscribe(opts = {}, &block)
Alias for: subscribe
subscribe(opts = {}, &block) click to toggle source
# File lib/em-synchrony/amqp.rb, line 158
def subscribe(opts = {}, &block)
  Fiber.new do
    asubscribe(opts, &EM::Synchrony::AMQP.sync_cb(Fiber.current))
    loop { block.call(Fiber.yield) }
  end.resume
end
Also aliased as: asubscribe