summaryrefslogtreecommitdiff
path: root/qpid/ruby/lib
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
commit09df5fef4ad0581922429b3078570df8820e34c9 (patch)
treeb2ba89fe64d206eb2c752adea6be099731694d02 /qpid/ruby/lib
parent4d3a365d2c7fc3326536818e3d33c4dd7df247df (diff)
downloadqpid-python-09df5fef4ad0581922429b3078570df8820e34c9.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@726751 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/ruby/lib')
-rw-r--r--qpid/ruby/lib/qpid/qmf.rb14
1 files changed, 7 insertions, 7 deletions
diff --git a/qpid/ruby/lib/qpid/qmf.rb b/qpid/ruby/lib/qpid/qmf.rb
index 222801b6cd..865e795c24 100644
--- a/qpid/ruby/lib/qpid/qmf.rb
+++ b/qpid/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