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
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