Module: Carrot::AMQP::Protocol

Defined in:

lib/amqp/protocol.rb,
lib/amqp/spec.rb,
lib/amqp/spec.rb

Defined Under Namespace

Classes: Access, Basic, Channel, Class, Connection, Dtx, Exchange, File, Header, Queue, Stream, Test, Tunnel, Tx

Class Method Summary

• .Class(id, name) ⇒ Object
• .classes ⇒ Object
• .parse(buf) ⇒ Object

Class Method Details

.Class(id, name) ⇒ Object

# File 'lib/amqp/spec.rb', line 118

def self.Class(id, name)
  @_base_classes ||= {}
  @_base_classes[id] ||= ::Class.new(Class) do
    class_eval %[
      def self.inherited klass
        klass.const_set(:ID, #{id})
        klass.const_set(:NAME, :#{name.to_s})
        Protocol.classes[#{id}] = klass
        Protocol.classes[klass::NAME] = klass
      end
    ]
  end
end

.classes ⇒ Object

# File 'lib/amqp/spec.rb', line 116

def self.classes() @classes ||= {} end

.parse(buf) ⇒ Object

# File 'lib/amqp/protocol.rb', line 151

def self.parse buf
  buf = Buffer.new(buf) unless buf.is_a? Buffer
  class_id, method_id = buf.read(:short, :short)
  classes[class_id].methods[method_id].new(buf)
end