[jboss-cvs] JBoss Messaging SVN: r4675 - trunk/examples/jms/src/org/jboss/jms/example.

[jboss-cvs-commits at lists.jboss.org]

Author: clebert.suconic at jboss.com
Date: 2008-07-10 19:41:50 -0400 (Thu, 10 Jul 2008)
New Revision: 4675

Modified:
   trunk/examples/jms/src/org/jboss/jms/example/PerfExample.java
Log:
Just adding a message on PerfListener (draw)

Modified: trunk/examples/jms/src/org/jboss/jms/example/PerfExample.java
===================================================================
--- trunk/examples/jms/src/org/jboss/jms/example/PerfExample.java	2008-07-10 10:15:44 UTC (rev 4674)
+++ trunk/examples/jms/src/org/jboss/jms/example/PerfExample.java	2008-07-10 23:41:50 UTC (rev 4675)
@@ -253,14 +253,19 @@
    private void drainQueue(final MessageConsumer consumer) throws JMSException
    {
       log.info("draining queue");
+      int msgs = 0;
       while (true)
       {
          Message m = consumer.receive(5000);
          if (m == null)
          {
-            log.info("queue is drained");
+            log.info("queue is drained(" + msgs + " messages)");
             break;
          }
+         else
+         {
+            msgs ++;
+         }
       }
    }