diff options
| author | Kenneth Anthony Giusti <kgiusti@apache.org> | 2010-05-21 17:39:51 +0000 |
|---|---|---|
| committer | Kenneth Anthony Giusti <kgiusti@apache.org> | 2010-05-21 17:39:51 +0000 |
| commit | a3462820c7f5af8bbb7300334c49d47b239fe901 (patch) | |
| tree | a7b80c797d774f43130dd67e9c6e00ca7fee1ced /cpp/bindings | |
| parent | b8d8b5b3b620e63052f60524ebb54ef0be92c6d1 (diff) | |
| download | qpid-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')
| -rw-r--r-- | cpp/bindings/qmf/python/qmf.py | 15 | ||||
| -rw-r--r-- | cpp/bindings/qmf/ruby/qmf.rb | 15 |
2 files changed, 29 insertions, 1 deletions
diff --git a/cpp/bindings/qmf/python/qmf.py b/cpp/bindings/qmf/python/qmf.py index 37442b94ea..06d3070841 100644 --- a/cpp/bindings/qmf/python/qmf.py +++ b/cpp/bindings/qmf/python/qmf.py @@ -1166,9 +1166,22 @@ class Console(Thread): if "class" in kwargs: self.impl.bindClass(package, kwargs["class"]) else: - self.impl.bindClass(package) + self.impl.bindClass(package, "*") else: raise Exception("Argument error: invalid arguments, use 'key' or 'package'[,'class']") + + + def bind_event(self, kwargs = {}): + if "key" in kwargs: + self.impl.bindEvent(kwargs["key"]) + elif "package" in kwargs: + package = kwargs["package"] + if "event" in kwargs: + self.impl.bindEvent(package, kwargs["event"]) + else: + self.impl.bindEvent(package, "*") + else: + raise Exception("Argument error: invalid arguments, use 'key' or 'package'[,'event']") def agents(self, broker=None): 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 |
