diff options
Diffstat (limited to 'ruby/lib')
-rw-r--r-- | ruby/lib/qpid/codec.rb | 8 | ||||
-rw-r--r-- | ruby/lib/qpid/datatypes.rb | 10 | ||||
-rw-r--r-- | ruby/lib/qpid/delegates.rb | 2 | ||||
-rw-r--r-- | ruby/lib/qpid/session.rb | 8 |
4 files changed, 14 insertions, 14 deletions
diff --git a/ruby/lib/qpid/codec.rb b/ruby/lib/qpid/codec.rb index 009b1eef53..e63323158e 100644 --- a/ruby/lib/qpid/codec.rb +++ b/ruby/lib/qpid/codec.rb @@ -370,7 +370,7 @@ module Qpid end def write_struct32(value) - type = value.type + type = value.st_type sc = StringCodec.new(@spec) sc.write_uint16(type.code) type.encode_fields(sc, value) @@ -383,7 +383,7 @@ module Qpid end def write_control(ctrl) - type = ctrl.type + type = ctrl.st_type write_uint16(type.code) type.encode_fields(self, ctrl) end @@ -396,9 +396,9 @@ module Qpid end def write_command(hdr, cmd) - type = cmd.type + type = cmd.st_type write_uint16(type.code) - hdr.type.encode(self, hdr) + hdr.st_type.encode(self, hdr) type.encode_fields(self, cmd) end diff --git a/ruby/lib/qpid/datatypes.rb b/ruby/lib/qpid/datatypes.rb index 96afe58dee..418388c73a 100644 --- a/ruby/lib/qpid/datatypes.rb +++ b/ruby/lib/qpid/datatypes.rb @@ -54,12 +54,12 @@ module Qpid [type.name, unexpected] end - attrs[:type] = type + attrs[:st_type] = type attrs[:id] = nil name = "Qpid_" + type.name.to_s.capitalize unless ::Struct.const_defined?(name) - vars = type.fields.collect { |f| f.name } << :type << :id + vars = type.fields.collect { |f| f.name } << :st_type << :id ::Struct.new(name, *vars) end st = ::Struct.const_get(name) @@ -90,13 +90,13 @@ module Qpid def get(name) if @headers name = name.to_sym - @headers.find { |h| h.type.name == name } + @headers.find { |h| h.st_type.name == name } end end def set(header) @headers ||= [] - if h = @headers.find { |h| h.type == header.type } + if h = @headers.find { |h| h.st_type == header.st_type } ind = @headers.index(h) @headers[ind] = header else @@ -107,7 +107,7 @@ module Qpid def clear(name) if @headers name = name.to_sym - @headers.delete_if { |h| h.type.name == name } + @headers.delete_if { |h| h.st_type.name == name } end end diff --git a/ruby/lib/qpid/delegates.rb b/ruby/lib/qpid/delegates.rb index 6d655067ef..f779047e05 100644 --- a/ruby/lib/qpid/delegates.rb +++ b/ruby/lib/qpid/delegates.rb @@ -44,7 +44,7 @@ module Qpid if seg.track == @control ctl = seg.decode(@spec) log.debug("RECV %s", ctl) if log - attr = ctl.type.name + attr = ctl.st_type.name method(attr).call(ch, ctl) elsif ssn.nil? ch.session_detached diff --git a/ruby/lib/qpid/session.rb b/ruby/lib/qpid/session.rb index 1b4d78814a..d693b722c2 100644 --- a/ruby/lib/qpid/session.rb +++ b/ruby/lib/qpid/session.rb @@ -277,13 +277,13 @@ module Qpid end log.debug("RECV %s %s %s" % [cmd.id, hdr, cmd]) if log - if cmd.type.payload - result = @delegate.send(cmd.type.name, cmd, header, body) + if cmd.st_type.payload + result = @delegate.send(cmd.st_type.name, cmd, header, body) else - result = @delegate.send(cmd.type.name, cmd) + result = @delegate.send(cmd.st_type.name, cmd) end - unless cmd.type.result.nil? + unless cmd.st_type.result.nil? execution_result(cmd.id, result) end |