Module: AMQ::Protocol

Defined in:
lib/amq/protocol/frame.rb,
lib/amq/protocol/table.rb,
lib/amq/protocol/client.rb,
lib/amq/protocol/version.rb,
lib/amq/protocol/constants.rb,
lib/amq/protocol/exceptions.rb,
lib/amq/protocol/float_32bit.rb,
lib/amq/protocol/type_constants.rb,
lib/amq/protocol/table_value_encoder.rb,
lib/amq/protocol/table_value_decoder.rb

Defined Under Namespace

Modules: TypeConstants Classes: AccessRefused, BadResponseError, Basic, BodyFrame, Channel, ChannelError, Class, CommandInvalid, Confirm, Connection, ConnectionForced, ContentTooLarge, EmptyResponseError, Error, Exchange, Float32Bit, Frame, FrameError, FrameSubclass, FrameTypeError, HardError, HeaderFrame, HeartbeatFrame, InternalError, InvalidPath, Method, MethodFrame, NoConsumers, NoRoute, NotAllowed, NotFound, NotImplemented, PreconditionFailed, Queue, ResourceError, ResourceLocked, SoftError, SyntaxError, Table, TableValueDecoder, TableValueEncoder, Tx, UnexpectedFrame

Constant Summary

PROTOCOL_VERSION =
"0.9.1".freeze
PREAMBLE =
"AMQP\x00\x00\x09\x01".freeze
DEFAULT_PORT =
5672
METHODS =
begin
  Method.methods.inject(Hash.new) do |hash, klass|
    hash.merge!(klass.index => klass)
  end
end
VERSION =
"1.10.0.pre"
TLS_PORT =
5671
SSL_PORT =
5671
EMPTY_STRING =

caching

"".freeze
PACK_INT8 =
'c'.freeze
PACK_CHAR =
'C'.freeze
PACK_UINT16 =
'n'.freeze
PACK_UINT16_X2 =
'n2'.freeze
PACK_UINT32 =
'N'.freeze
PACK_UINT32_X2 =
'N2'.freeze
PACK_INT64 =
'q'.freeze
PACK_UCHAR_UINT32 =
'CN'.freeze
PACK_CHAR_UINT16_UINT32 =
'cnN'.freeze
PACK_32BIT_FLOAT =
'f'.freeze
PACK_64BIT_FLOAT =
'G'.freeze

Class Method Summary (collapse)

Class Method Details

+ (Array) classes



22
23
24
# File 'lib/amq/protocol/client.rb', line 22

def self.classes
  Protocol::Class.classes
end

+ (Array) methods



27
28
29
# File 'lib/amq/protocol/client.rb', line 27

def self.methods
  Protocol::Method.methods
end