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