QPID-2991: added message counts to connection stats; fixed xxxToClient stats

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1057578 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 30 insertions, 0 deletions

diff --git a/qpid/tests/src/py/qpid_tests/broker_0_10/management.py b/qpid/tests/src/py/qpid_tests/broker_0_10/management.py
index 1e579debf4..06f3212a6f 100644
--- a/qpid/tests/src/py/qpid_tests/broker_0_10/management.py
+++ b/qpid/tests/src/py/qpid_tests/broker_0_10/management.py
@@ -490,3 +490,33 @@ class ManagementTest (TestBase010):
         self.assertEqual(queue.bindingCount, 1,
                          "deleted bindings not accounted for (expected 1, got %d)" % queue.bindingCount)
 
+    def test_connection_stats(self):
+        """
+        Test message in/out stats for connection
+        """
+        self.startQmf()
+        conn = self.connect()
+        session = conn.session("stats-session")
+
+        #using qmf find named session and the corresponding connection:
+        conn_qmf = self.qmf.getObjects(_class="session", name="stats-session")[0]._connectionRef_
+        
+        #send a message to a queue
+        session.queue_declare(queue="stats-q", exclusive=True, auto_delete=True)
+        session.message_transfer(message=Message(session.delivery_properties(routing_key="stats-q"), "abc"))
+        
+        #check the 'msgs sent from' stat for this connection
+        conn_qmf.update()
+        self.assertEqual(conn_qmf.msgsFromClient, 1)
+
+        #receive message from queue
+        session.message_subscribe(destination="d", queue="stats-q")
+        incoming = session.incoming("d")
+        incoming.start()
+        self.assertEqual("abc", incoming.get(timeout=1).body)
+
+        #check the 'msgs sent to' stat for this connection
+        conn_qmf.update()
+        self.assertEqual(conn_qmf.msgsToClient, 1)
+
+