Contents

# encoding: utf-8

require "amqp/exceptions"

module AMQP
  module Framing
    module String
      class Frame < AMQ::Protocol::Frame
        ENCODINGS_SUPPORTED = defined? Encoding
        HEADER_SLICE = (0..6).freeze
        DATA_SLICE = (7..-1).freeze
        PAYLOAD_SLICE = (0..-2).freeze

        def self.decode(string)
          header              = string[HEADER_SLICE]
          type, channel, size = self.decode_header(header)
          data                = string[DATA_SLICE]
          payload             = data[PAYLOAD_SLICE]
          frame_end           = data[-1, 1]

          frame_end.force_encoding(AMQ::Protocol::Frame::FINAL_OCTET.encoding) if ENCODINGS_SUPPORTED

          # 1) the size is miscalculated
          if payload.bytesize != size
            raise BadLengthError.new(size, payload.bytesize)
          end

          # 2) the size is OK, but the string doesn't end with FINAL_OCTET
          raise NoFinalOctetError.new if frame_end != AMQ::Protocol::Frame::FINAL_OCTET

          self.new(type, payload, channel)
        end # self.from
      end # Frame
    end # String
  end # Framing
end # AMQP

Version data entries

24 entries across 24 versions & 1 rubygems

Version	Path
amqp-1.1.1	lib/amqp/framing/string/frame.rb
amqp-1.1.0	lib/amqp/framing/string/frame.rb
amqp-1.1.0.rc1	lib/amqp/framing/string/frame.rb
amqp-1.1.0.pre2	lib/amqp/framing/string/frame.rb