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_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, 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 collapse
- 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 =
"2.3.2"
- 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_UINT64_BE =
'Q>'.freeze
- PACK_INT64 =
'q'.freeze
- PACK_INT64_BE =
'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
-
.classes ⇒ Array
Collection of subclasses of AMQ::Protocol::Class.
-
.methods ⇒ Array
Collection of subclasses of AMQ::Protocol::Method.