Module AMQ::Protocol
In: lib/amq/protocol/client.rb
lib/amq/protocol/table.rb
lib/amq/protocol/table_value_encoder.rb
lib/amq/protocol/table_value_decoder.rb
lib/amq/protocol/frame.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.4"

Public Class methods

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

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

[Validate]