diff options
| author | Ted Ross <tross@apache.org> | 2008-12-15 18:11:47 +0000 |
|---|---|---|
| committer | Ted Ross <tross@apache.org> | 2008-12-15 18:11:47 +0000 |
| commit | 25fdda002812812330ff56874c103848107aebd8 (patch) | |
| tree | b66d37723bd84910a0779c4a17d61179a56de539 /ruby | |
| parent | 4d5f35f824f95835f6d3d30fef88fd8a68e7a14d (diff) | |
| download | qpid-python-25fdda002812812330ff56874c103848107aebd8.tar.gz | |
Suppress spurious object updates when :rcv_objects => false.
Fixed a typo in the definition of Qpid::Qmf::Console.
Fixed a bug in Session-initialize that caused boolean arguments to be ignored.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@726751 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'ruby')
| -rw-r--r-- | ruby/lib/qpid/qmf.rb | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/ruby/lib/qpid/qmf.rb b/ruby/lib/qpid/qmf.rb index 222801b6cd..865e795c24 100644 --- a/ruby/lib/qpid/qmf.rb +++ b/ruby/lib/qpid/qmf.rb @@ -53,7 +53,7 @@ module Qpid::Qmf def object_props(broker, record); end # Invoked when an object is updated - def objectStats(broker, record); end + def object_stats(broker, record); end # Invoked when an event is raised def event(broker, event); end @@ -151,10 +151,10 @@ module Qpid::Qmf @result = [] @select = [] @error = nil - @rcv_objects = kwargs[:rcv_objects] || true - @rcv_events = kwargs[:rcv_events] || true - @rcv_heartbeats = kwargs[:rcv_heartbeats] || true - @user_bindings = kwargs[:user_bindings] || false + @rcv_objects = kwargs[:rcv_objects] == nil ? true : kwargs[:rcv_objects] + @rcv_events = kwargs[:rcv_events] == nil ? true : kwargs[:rcv_events] + @rcv_heartbeats = kwargs[:rcv_heartbeats] == nil ? true : kwargs[:rcv_heartbeats] + @user_bindings = kwargs[:user_bindings] == nil ? false : kwargs[:user_bindings] unless @console @rcv_objects = false @rcv_events = false @@ -559,8 +559,8 @@ module Qpid::Qmf end end - @console.object_props(broker, object) if @console && prop - @console.object_stats(broker, object) if @console && stat + @console.object_props(broker, object) if @console && @rcv_objects && prop + @console.object_stats(broker, object) if @console && @rcv_objects && stat end def handle_broker_disconnect(broker); end |
