summaryrefslogtreecommitdiff
path: root/ruby
diff options
context:
space:
mode:
authorTed Ross <tross@apache.org>2008-12-15 18:11:47 +0000
committerTed Ross <tross@apache.org>2008-12-15 18:11:47 +0000
commit25fdda002812812330ff56874c103848107aebd8 (patch)
treeb66d37723bd84910a0779c4a17d61179a56de539 /ruby
parent4d5f35f824f95835f6d3d30fef88fd8a68e7a14d (diff)
downloadqpid-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.rb14
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