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

.classesArray

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

Returns:

  • (Array)

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



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

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.



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

def self.methods
  Protocol::Method.methods
end