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(&block) ⇒ Object
Constructor Details
#initialize(*params) ⇒ Queue
Returns a new instance of Queue.
137 138 139 140 141 142 143 |
# File 'lib/em-synchrony/amqp.rb', line 137 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
145 |
# File 'lib/em-synchrony/amqp.rb', line 145 alias :asubscribe :subscribe |