Class: EventMachine::Synchrony::AMQP::Queue
- Inherits:
-
AMQP::Queue
- Object
- AMQP::Queue
- EventMachine::Synchrony::AMQP::Queue
- Defined in:
- lib/em-synchrony/amqp.rb
Instance Method Summary collapse
- #asubscribe ⇒ Object
-
#initialize(*params) ⇒ Queue
constructor
A new instance of Queue.
- #subscribe(opts = {}, &block) ⇒ Object
Constructor Details
#initialize(*params) ⇒ Queue
Returns a new instance of Queue.
149 150 151 152 153 154 155 |
# 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 |
Instance Method Details
#asubscribe ⇒ Object
157 |
# File 'lib/em-synchrony/amqp.rb', line 157 alias :asubscribe :subscribe |