Contents

#:stopdoc:
# this file was autogenerated on 2009-12-13 13:38:22 +0000
#
# DO NOT EDIT! (edit ext/qparser.rb and config.yml instead, and run 'ruby qparser.rb')

module Qrack
  module Transport09
    class Frame

      FOOTER = 206
      ID = 0

      @types = {
                 1 => 'Method',
                 2 => 'Header',
                 3 => 'Body',
                 8 => 'Heartbeat',
               }

      attr_accessor :channel, :payload

      def initialize payload = nil, channel = 0
        @channel, @payload = channel, payload
      end

      def id
        self.class::ID
      end

      def to_binary
        buf = Transport09::Buffer.new
        buf.write :octet, id
        buf.write :short, channel
        buf.write :longstr, payload
        buf.write :octet, FOOTER
        buf.rewind
        buf
      end

      def to_s
        to_binary.to_s
      end

      def == frame
        [ :id, :channel, :payload ].inject(true) do |eql, field|
          eql and __send__(field) == frame.__send__(field)
        end
      end

      def self.parse buf
        buf = Transport09::Buffer.new(buf) unless buf.is_a? Transport09::Buffer
        buf.extract do
          id, channel, payload, footer = buf.read(:octet, :short, :longstr, :octet)
          Qrack::Transport09.const_get(@types[id]).new(payload, channel) if footer == FOOTER
        end
      end

    end

    class Method < Frame
	
      ID = 1
	
      def initialize payload = nil, channel = 0
        super
        unless @payload.is_a? Protocol09::Class::Method or @payload.nil?
          @payload = Protocol09.parse(@payload)
        end
      end
    end

    class Header < Frame

      ID = 2

      def initialize payload = nil, channel = 0
        super
        unless @payload.is_a? Protocol09::Header or @payload.nil?
          @payload = Protocol09::Header.new(@payload)
        end
      end
    end

    class Body < Frame
      ID = 3
    end

    class Heartbeat < Frame
      ID = 8
    end

  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
bunny-0.6.3.rc2	lib/qrack/transport/frame09.rb
bunny-0.6.3.rc1	lib/qrack/transport/frame09.rb