summaryrefslogtreecommitdiff
path: root/cpp/bindings/qmf/ruby
diff options
context:
space:
mode:
authorKenneth Anthony Giusti <kgiusti@apache.org>2010-05-21 17:39:51 +0000
committerKenneth Anthony Giusti <kgiusti@apache.org>2010-05-21 17:39:51 +0000
commita3462820c7f5af8bbb7300334c49d47b239fe901 (patch)
treea7b80c797d774f43130dd67e9c6e00ca7fee1ced /cpp/bindings/qmf/ruby
parentb8d8b5b3b620e63052f60524ebb54ef0be92c6d1 (diff)
downloadqpid-python-a3462820c7f5af8bbb7300334c49d47b239fe901.tar.gz
QMF: add bindEvent api to allow filtering of unsolicted events.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@947084 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'cpp/bindings/qmf/ruby')
-rw-r--r--cpp/bindings/qmf/ruby/qmf.rb15
1 files changed, 15 insertions, 0 deletions
diff --git a/cpp/bindings/qmf/ruby/qmf.rb b/cpp/bindings/qmf/ruby/qmf.rb
index e50d23a0e0..34d3255d8d 100644
--- a/cpp/bindings/qmf/ruby/qmf.rb
+++ b/cpp/bindings/qmf/ruby/qmf.rb
@@ -1087,6 +1087,21 @@ module Qmf
end
end
+ def bind_event(kwargs = {})
+ if kwargs.include?(:key)
+ @impl.bindEvent(kwargs[:key])
+ elsif kwargs.include?(:package)
+ package = kwargs[:package]
+ if kwargs.include?(:event)
+ @impl.bindEvent(package, kwargs[:event])
+ else
+ @impl.bindEvent(package, "*")
+ end
+ else
+ raise ArgumentError, "Invalid arguments, use :key or :package[,:event]"
+ end
+ end
+
def agents(broker = nil)
blist = []
if broker