summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorPavel Moravec <pmoravec@apache.org>2014-06-02 13:56:12 +0000
committerPavel Moravec <pmoravec@apache.org>2014-06-02 13:56:12 +0000
commit9b03012515b9aea91c0ba13c6c899115de8f476e (patch)
tree6db2a6d27400975dd1722c342de463f435ab23c5
parentb70b644bed96839095952b99af9ce3fa887969d1 (diff)
downloadqpid-python-9b03012515b9aea91c0ba13c6c899115de8f476e.tar.gz
QPID-5797: [qpid-tools]: inability to call some QMF methods (queueMoveMessages / setLogLevel or so)
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1599221 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--qpid/tools/src/py/qpidtoollibs/broker.py22
1 files changed, 17 insertions, 5 deletions
diff --git a/qpid/tools/src/py/qpidtoollibs/broker.py b/qpid/tools/src/py/qpidtoollibs/broker.py
index f6243bbba5..c584ea1681 100644
--- a/qpid/tools/src/py/qpidtoollibs/broker.py
+++ b/qpid/tools/src/py/qpidtoollibs/broker.py
@@ -210,23 +210,35 @@ class BrokerAgent(object):
def queueMoveMessages(self, srcQueue, destQueue, qty):
"""Move messages from one queue to another"""
- pass
+ self._method("queueMoveMessages", {'srcQueue':srcQueue,'destQueue':destQueue,'qty':qty})
+
+ def queueRedirect(self, sourceQueue, targetQueue):
+ """Enable/disable delivery redirect for indicated queues"""
+ self._method("queueRedirect", {'sourceQueue':sourceQueue,'targetQueue':targetQueue})
def setLogLevel(self, level):
"""Set the log level"""
- pass
+ self._method("setLogLevel", {'level':level})
def getLogLevel(self):
"""Get the log level"""
- pass
+ return self._method('getLogLevel')
def setTimestampConfig(self, receive):
"""Set the message timestamping configuration"""
- pass
+ self._method("setTimestampConfig", {'receive':receive})
def getTimestampConfig(self):
"""Get the message timestamping configuration"""
- pass
+ return self._method('getTimestampConfig')
+
+ def setLogHiresTimestamp(self, logHires):
+ """Set the high resolution timestamp in logs"""
+ self._method("setLogHiresTimestamp", {'logHires':logHires})
+
+ def getLogHiresTimestamp(self):
+ """Get the high resolution timestamp in logs"""
+ return self._method('getLogHiresTimestamp')
def addExchange(self, exchange_type, name, options={}, **kwargs):
properties = {}