Class: EventMachine::Synchrony::AMQP::Consumer
- Inherits:
-
AMQP::Consumer
- Object
- AMQP::Consumer
- EventMachine::Synchrony::AMQP::Consumer
- Defined in:
- lib/em-synchrony/amqp.rb
Instance Method Summary collapse
- #acancel ⇒ Object
- #aconsume ⇒ Object
- #aon_delivery ⇒ Object
- #aresubscribe ⇒ Object
- #cancel(nowait = false) ⇒ Object
- #consume(nowait = false) ⇒ Object
- #on_delivery(&block) ⇒ Object
- #resubscribe ⇒ Object
Instance Method Details
#acancel ⇒ Object
109 |
# File 'lib/em-synchrony/amqp.rb', line 109 alias :acancel :cancel |
#aconsume ⇒ Object
96 |
# File 'lib/em-synchrony/amqp.rb', line 96 alias :aconsume :consume |
#aon_delivery ⇒ Object
87 |
# File 'lib/em-synchrony/amqp.rb', line 87 alias :aon_delivery :on_delivery |
#aresubscribe ⇒ Object
103 |
# File 'lib/em-synchrony/amqp.rb', line 103 alias :aresubscribe :resubscribe |
#cancel(nowait = false) ⇒ Object
110 111 112 113 |
# File 'lib/em-synchrony/amqp.rb', line 110 def cancel(nowait = false) EM::Synchrony::AMQP.sync { |f| self.aconsume(nowait, &EM::Synchrony::AMQP.sync_cb(f)) } self end |
#consume(nowait = false) ⇒ Object
97 98 99 100 101 |
# File 'lib/em-synchrony/amqp.rb', line 97 def consume(nowait = false) ret = EM::Synchrony::AMQP.sync { |f| self.aconsume(nowait, &EM::Synchrony::AMQP.sync_cb(f)) } raise Error.new(ret.to_s) unless ret.is_a?(::AMQ::Protocol::Basic::ConsumeOk) self end |