Module: Carrot::AMQP

Defined in:: lib/carrot.rb,
lib/carrot/amqp/spec.rb,
lib/carrot/amqp/spec.rb,
lib/carrot/amqp/frame.rb,
lib/carrot/amqp/queue.rb,
lib/carrot/amqp/buffer.rb,
lib/carrot/amqp/header.rb,
lib/carrot/amqp/server.rb,
lib/carrot/amqp/exchange.rb,
lib/carrot/amqp/protocol.rb

Defined Under Namespace

Modules: Protocol Classes: Buffer, Exchange, Frame, Header, Queue, Server

Constant Summary collapse

HEADER =

"AMQP".freeze

VERSION_MAJOR =

VERSION_MINOR =

PORT =

RESPONSES =

{
  200 => :REPLY_SUCCESS,
  310 => :NOT_DELIVERED,
  311 => :CONTENT_TOO_LARGE,
  312 => :NO_ROUTE,
  313 => :NO_CONSUMERS,
  403 => :ACCESS_REFUSED,
  404 => :NOT_FOUND,
  405 => :RESOURCE_LOCKED,
  406 => :PRECONDITION_FAILED,
  320 => :CONNECTION_FORCED,
  402 => :INVALID_PATH,
}

FIELDS =

[
  :bit,
  :long,
  :longlong,
  :longstr,
  :octet,
  :short,
  :shortstr,
  :table,
  :timestamp,
]