diff options
| author | Pavel Moravec <pmoravec@apache.org> | 2014-06-02 13:56:12 +0000 |
|---|---|---|
| committer | Pavel Moravec <pmoravec@apache.org> | 2014-06-02 13:56:12 +0000 |
| commit | 9b03012515b9aea91c0ba13c6c899115de8f476e (patch) | |
| tree | 6db2a6d27400975dd1722c342de463f435ab23c5 | |
| parent | b70b644bed96839095952b99af9ce3fa887969d1 (diff) | |
| download | qpid-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.py | 22 |
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 = {} |
