VERSION | = | "0.9.4" | ||
SIMPLE_BYTE_PACK | = | 'c*' | ||
CLASSES | = | { Frame::TYPES[:method] => MethodFrame, Frame::TYPES[:headers] => HeaderFrame, Frame::TYPES[:body] => BodyFrame, Frame::TYPES[:heartbeat] => HeartbeatFrame | ||
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) |