Permalink
Browse files

These fields are missing from broker, removed.

We aren't using them, but this is concerning. Presumably their absence is because of different broker settings?
  • Loading branch information...
labisso committed Oct 25, 2010
1 parent 3f55b42 commit d844cd24e87935de0caf87d0d6e30263b3d2a1a6
Showing with 7 additions and 9 deletions.
  1. +7 −9 txrabbitmq/service.py
View
@@ -9,8 +9,7 @@
QUEUE_INFO_ITEMS = ["name", "durable", "auto_delete", "arguments", "pid",
-"messages_ready", "messages_unacknowledged", "messages_uncommitted", "messages", "acks_uncommitted",
-"consumers", "transactions", "memory"]
+"messages_ready", "messages_unacknowledged", "messages", "consumers", "memory"]
EXCHANGE_INFO_ITEMS = ["name", "type", "durable", "auto_delete", "arguments"]
@@ -155,9 +154,11 @@ def list_queues(self, vhostpath=None, queueinfoitem=None):
if vhostpath is None:
vhostpath = "/"
vhostpath = Binary(vhostpath)
+
if queueinfoitem is None:
infoitems = [Atom(item) for item in QUEUE_INFO_ITEMS]
- result = yield self.process.callRemote(self.remote_nodename, "rabbit_amqqueue", "info_all", vhostpath, infoitems)
+ result = yield self.process.callRemote(self.remote_nodename, "rabbit_amqqueue",
+ "info_all", vhostpath, infoitems)
info_all = []
for v in result:
info_all.append((v[0][1][3].value,
@@ -168,12 +169,9 @@ def list_queues(self, vhostpath=None, queueinfoitem=None):
"pid":v[4][1].nodeName.text,
"messages_ready":v[5][1],
"messages_unacknowledged":v[6][1],
- "messages_uncommitted":v[7][1],
- "messages":v[8][1],
- "acks_uncommitted":v[9][1],
- "memory":v[10][1],
- "transactions":v[11][1],
- "memory":v[12][1]}))
+ "messages":v[7][1],
+ "consumers":v[8][1],
+ "memory":v[9][1]}))
response = {"command":"list_queues", "vhostpath":vhostpath.value, "result":info_all}
returnValue(response)

0 comments on commit d844cd2

Please sign in to comment.