Module AMQ::Protocol
In: lib/amq/protocol/client.rb
lib/amq/protocol/frame.rb
lib/amq/protocol/table.rb
lib/amq/protocol/table_value_decoder.rb
lib/amq/protocol/table_value_encoder.rb
lib/amq/protocol/type_constants.rb
lib/amq/protocol/version.rb

Methods

classes   methods  

Classes and Modules

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

Constants

PROTOCOL_VERSION = "0.9.1".freeze
PREAMBLE = "AMQP\x00\x00\x09\x01".freeze
DEFAULT_PORT = 5672
EMPTY_STRING = "".freeze   caching
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 = "d".freeze
METHODS = begin Method.methods.inject(Hash.new) do |hash, klass| hash.merge!(klass.index => klass)
SIMPLE_BYTE_PACK = 'c*'
CLASSES = { Frame::TYPES[:method] => MethodFrame, Frame::TYPES[:headers] => HeaderFrame, Frame::TYPES[:body] => BodyFrame, Frame::TYPES[:heartbeat] => HeartbeatFrame
VERSION = "0.9.0"

Public Class methods

@return [Array] Collection of subclasses of AMQ::Protocol::Class.

@return [Array] Collection of subclasses of AMQ::Protocol::Method.

[Validate]