summaryrefslogtreecommitdiff
path: root/tools/src
diff options
context:
space:
mode:
authorCharles E. Rolke <chug@apache.org>2013-05-23 19:38:09 +0000
committerCharles E. Rolke <chug@apache.org>2013-05-23 19:38:09 +0000
commit03ffba4b8d4c3bb86b607362e4950da2d37d774a (patch)
treef7438492b2fa3f43a9075ac0010215ef063c020c /tools/src
parentd741dd4b6ea280bda9b887bf2fd826e891eea34f (diff)
downloadqpid-python-03ffba4b8d4c3bb86b607362e4950da2d37d774a.tar.gz
QPID-4650: C++ Broker method to redirect messages between two queues.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1485836 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'tools/src')
-rw-r--r--tools/src/py/qpidtoollibs/broker.py5
1 files changed, 5 insertions, 0 deletions
diff --git a/tools/src/py/qpidtoollibs/broker.py b/tools/src/py/qpidtoollibs/broker.py
index c496ab0908..4fad8cc8ad 100644
--- a/tools/src/py/qpidtoollibs/broker.py
+++ b/tools/src/py/qpidtoollibs/broker.py
@@ -292,6 +292,11 @@ class BrokerAgent(object):
'routingKey': key}
return self._method('LookupPublish', args, "org.apache.qpid.acl:acl:org.apache.qpid.broker:broker:amqp-broker")
+ def Redirect(self, sourceQueue, targetQueue):
+ args = {'sourceQueue': sourceQueue,
+ 'targetQueue': targetQueue}
+ return self._method('queueRedirect', args, "org.apache.qpid.broker:broker:amqp-broker")
+
def create(self, _type, name, properties={}, strict=False):
"""Create an object of the specified type"""
args = {'type': _type,