diff options
author | Ted Ross <tross@apache.org> | 2013-10-08 22:47:32 +0000 |
---|---|---|
committer | Ted Ross <tross@apache.org> | 2013-10-08 22:47:32 +0000 |
commit | bf75e3b8594f0c46a0733e516854cb2ca12c53cc (patch) | |
tree | c1bab189175c2fac645011c6b266bd3c541ad0fc /extras | |
parent | 8a1cc51f5cd1c7d9b76c47d5c01f7ffa59e91321 (diff) | |
download | qpid-python-bf75e3b8594f0c46a0733e516854cb2ca12c53cc.tar.gz |
QPID-5213 - Added -n option to qdstat to display router-node information.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1530456 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'extras')
-rwxr-xr-x | extras/dispatch/tools/src/py/qdstat | 42 |
1 files changed, 42 insertions, 0 deletions
diff --git a/extras/dispatch/tools/src/py/qdstat b/extras/dispatch/tools/src/py/qdstat index f9895b0198..869d38cf66 100755 --- a/extras/dispatch/tools/src/py/qdstat +++ b/extras/dispatch/tools/src/py/qdstat @@ -164,6 +164,48 @@ class BusManager: dispRows = rows disp.formattedTable(title, heads, dispRows) + def displayRouterNodes(self): + disp = Display(prefix=" ") + heads = [] + heads.append(Header("class")) + heads.append(Header("address")) + heads.append(Header("rindex")) + heads.append(Header("next-hop")) + heads.append(Header("link")) + rows = [] + + request = Message() + response = Message() + + request.address = self.address + request.reply_to = self.reply + request.correlation_id = 1 + request.properties = {u'operation':u'GET', u'type':u'org.apache.qpid.dispatch.router.node'} + + self.M.put(request) + self.M.send() + + self.M.recv() + self.M.get(response) + + for node in response.body: + row = [] + row.append(self._addr_class(node['addr'])) + row.append(self._addr_text(node['addr'])) + row.append(node['index']) + if node['next-hop'] != None: + row.append(node['next-hop']) + else: + row.append('-') + if node['router-link'] != None: + row.append(node['router-link']) + else: + row.append('-') + rows.append(row) + title = "Router Nodes" + dispRows = rows + disp.formattedTable(title, heads, dispRows) + def displayAddresses(self): disp = Display(prefix=" ") heads = [] |