diff options
| author | Gordon Sim <gsim@apache.org> | 2013-06-26 17:52:25 +0000 |
|---|---|---|
| committer | Gordon Sim <gsim@apache.org> | 2013-06-26 17:52:25 +0000 |
| commit | 3440b9189772b355b72b24ced083b0dac71cacb7 (patch) | |
| tree | 971526e73c9929118da47a09df83053ba5395da9 /qpid/tests/src/py | |
| parent | 4a1a41612aaeb0414b1b362123b02b388b34c1bf (diff) | |
| download | qpid-python-3440b9189772b355b72b24ced083b0dac71cacb7.tar.gz | |
QPID-4950: ensure exchange stats are updated with correct content size for messages
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1497024 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/tests/src/py')
| -rw-r--r-- | qpid/tests/src/py/qpid_tests/broker_0_10/stats.py | 33 |
1 files changed, 33 insertions, 0 deletions
diff --git a/qpid/tests/src/py/qpid_tests/broker_0_10/stats.py b/qpid/tests/src/py/qpid_tests/broker_0_10/stats.py index d78366a616..d36cc79acc 100644 --- a/qpid/tests/src/py/qpid_tests/broker_0_10/stats.py +++ b/qpid/tests/src/py/qpid_tests/broker_0_10/stats.py @@ -63,6 +63,39 @@ class BrokerStatsTests(Base): def setup_access(self): return BrokerAgent(self.conn) + def test_exchange_stats(self): + agent = self.setup_access() + start_broker = agent.getBroker() + + agent.addExchange("direct", "stats-test-exchange") + sess = self.setup_session() + tx_a = sess.sender("stats-test-exchange/a") + tx_b = sess.sender("stats-test-exchange/b") + rx_a = sess.receiver("stats-test-exchange/a") + + exchange = agent.getExchange("stats-test-exchange") + self.failUnless(exchange, "expected a valid exchange object") + self.assertEqual(exchange.msgReceives, 0, "msgReceives") + self.assertEqual(exchange.msgDrops, 0, "msgDrops") + self.assertEqual(exchange.msgRoutes, 0, "msgRoutes") + self.assertEqual(exchange.byteReceives, 0, "byteReceives") + self.assertEqual(exchange.byteDrops, 0, "byteDrops") + self.assertEqual(exchange.byteRoutes, 0, "byteRoutes") + + tx_a.send("0123456789") + tx_b.send("01234567890123456789") + tx_a.send("012345678901234567890123456789") + tx_b.send("0123456789012345678901234567890123456789") + + exchange.update() + self.assertEqual(exchange.msgReceives, 4, "msgReceives") + self.assertEqual(exchange.msgDrops, 2, "msgDrops") + self.assertEqual(exchange.msgRoutes, 2, "msgRoutes") + self.assertEqual(exchange.byteReceives, 100, "byteReceives") + self.assertEqual(exchange.byteDrops, 60, "byteDrops") + self.assertEqual(exchange.byteRoutes, 40, "byteRoutes") + + agent.delExchange("stats-test-exchange") def test_enqueues_dequeues(self): agent = self.setup_access() |