diff options
| author | Ted Ross <tross@apache.org> | 2009-06-11 15:54:37 +0000 |
|---|---|---|
| committer | Ted Ross <tross@apache.org> | 2009-06-11 15:54:37 +0000 |
| commit | 641f048cb8b86be0304441a6227759d7ad420ff3 (patch) | |
| tree | e450e074085d41a476a3c2d6daafcfe99183a60f /qpid/ruby/lib | |
| parent | 91f06a93d86eff2a597347dc2f15b2431eb0feae (diff) | |
| download | qpid-python-641f048cb8b86be0304441a6227759d7ad420ff3.tar.gz | |
QPID-1786 - Committed qmf patches from Bryan Kearney
Additionally updated existing qmf and Qman to be compatible.
The magic number for qmf messages has been incremented.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@783818 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/ruby/lib')
| -rw-r--r-- | qpid/ruby/lib/qpid/qmf.rb | 14 |
1 files changed, 9 insertions, 5 deletions
diff --git a/qpid/ruby/lib/qpid/qmf.rb b/qpid/ruby/lib/qpid/qmf.rb index b7309155c3..56037fff62 100644 --- a/qpid/ruby/lib/qpid/qmf.rb +++ b/qpid/ruby/lib/qpid/qmf.rb @@ -773,10 +773,16 @@ module Qpid::Qmf @methods = [] @arguments = [] + has_supertype = codec.read_uint8 if @kind == CLASS_KIND_TABLE prop_count = codec.read_uint16 stat_count = codec.read_uint16 method_count = codec.read_uint16 + if has_supertype == 1 + codec.read_str8 + codec.read_str8 + codec.read_bin128 + end prop_count.times { |idx| @properties << SchemaProperty.new(codec) } stat_count.times { |idx| @@ -1111,13 +1117,11 @@ module Qpid::Qmf def invoke(method, name, args) kwargs = args[args.size - 1] sync = true - timeout = nil + timeout = DEFAULT_METHOD_WAIT_TIME if kwargs.class == Hash if kwargs.include?(:timeout) timeout = kwargs[:timeout] - else - timeout = DEFAULT_METHOD_WAIT_TIME end if kwargs.include?(:async) @@ -1343,7 +1347,7 @@ module Qpid::Qmf def set_header(codec, opcode, seq=0) codec.write_uint8(?A) codec.write_uint8(?M) - codec.write_uint8(?2) + codec.write_uint8(?3) codec.write_uint8(opcode) codec.write_uint32(seq) end @@ -1508,7 +1512,7 @@ module Qpid::Qmf begin return [nil, nil] unless codec.read_uint8 == ?A return [nil, nil] unless codec.read_uint8 == ?M - return [nil, nil] unless codec.read_uint8 == ?2 + return [nil, nil] unless codec.read_uint8 == ?3 opcode = codec.read_uint8 seq = codec.read_uint32 return [opcode, seq] |