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

aqueue!(name, opts = {})
Alias for: queue!
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!