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/type_constants.rb,
lib/amq/protocol/table_value_decoder.rb,
lib/amq/protocol/table_value_encoder.rb

Defined Under Namespace

Modules: TypeConstants Classes: AccessRefused, BadResponseError, Basic, BodyFrame, Channel, ChannelError, Class, CommandInvalid, Confirm, Connection, ConnectionForced, ContentTooLarge, EmptyResponseError, Error, Exchange, 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 collapse

SIMPLE_BYTE_PACK =
'c*'
PROTOCOL_VERSION =
"0.9.1".freeze
PREAMBLE =
"AMQP\x00\x00\x09\x01".freeze
DEFAULT_PORT =
5672
EMPTY_STRING =

caching

"".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 =
"d".freeze
METHODS =
begin
  Method.methods.inject(Hash.new) do |hash, klass|
    hash.merge!(klass.index => klass)
  end
end
VERSION =
"0.7.0"

Class Method Summary collapse

Class Method Details

.classesArray

Returns Collection of subclasses of AMQ::Protocol::Class.

Returns:

  • (Array)

    Collection of subclasses of AMQ::Protocol::Class.



33
34
35
# File 'lib/amq/protocol/client.rb', line 33

def self.classes
  Protocol::Class.classes
end

.methodsArray

Returns Collection of subclasses of AMQ::Protocol::Method.

Returns:

  • (Array)

    Collection of subclasses of AMQ::Protocol::Method.



38
39
40
# File 'lib/amq/protocol/client.rb', line 38

def self.methods
  Protocol::Method.methods
end