class EventMachine::Synchrony::AMQP::Channel
Public Class Methods
new(*params, &block)
click to toggle source
Calls superclass method
# File lib/em-synchrony/amqp.rb, line 42 def initialize(*params, &block) f = Fiber.current super(*params, &EM::Synchrony::AMQP.sync_cb(f)) channel, open_ok = Fiber.yield raise Error.new unless open_ok.is_a?(::AMQ::Protocol::Channel::OpenOk) channel end
Public Instance Methods
queue!(name, opts = {})
click to toggle source
# File lib/em-synchrony/amqp.rb, line 68 def queue!(name, opts = {}) queue = Queue.new(self, name, opts) register_queue(queue) end
Also aliased as: aqueue!