lib/amqp/protocol.rb in tmm1-amqp-0.5.9 vs lib/amqp/protocol.rb in tmm1-amqp-0.6.0

- old
+ new

@@ -1,10 +1,11 @@ require 'amqp/spec' require 'amqp/buffer' module AMQP module Protocol + #:stopdoc: class Class::Method def initialize *args opts = args.pop if args.last.is_a? Hash opts ||= {} @@ -62,10 +63,33 @@ def to_frame channel = 0 Frame::Method.new(self, channel) end end + #:startdoc: + # + # Contains a properties hash that holds some potentially interesting + # information. + # * :delivery_mode + # 1 equals transient. + # 2 equals persistent. Unconsumed persistent messages will survive + # a server restart when they are stored in a durable queue. + # * :redelivered + # True or False + # * :routing_key + # The routing string used for matching this message to this queue. + # * :priority + # An integer in the range of 0 to 9 inclusive. + # * :content_type + # Always "application/octet-stream" (byte stream) + # * :exchange + # The source exchange which published this message. + # * :message_count + # The number of unconsumed messages contained in the queue. + # * :delivery_tag + # A monotonically increasing integer. This number should not be trusted + # as a sequence number. There is no guarantee it won't get reset. class Header def initialize *args opts = args.pop if args.last.is_a? Hash opts ||= {} @@ -130,9 +154,10 @@ def self.parse buf buf = Buffer.new(buf) unless buf.is_a? Buffer class_id, method_id = buf.read(:short, :short) classes[class_id].methods[method_id].new(buf) end + #:stopdoc: end end if $0 =~ /bacon/ or $0 == __FILE__ require 'bacon' \ No newline at end of file