activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rajdav...@apache.org
Subject svn commit: r577683 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/QueueWorkerPrefetchTest.java
Date Thu, 20 Sep 2007 11:09:32 GMT
Author: rajdavies
Date: Thu Sep 20 04:09:32 2007
New Revision: 577683

URL: http://svn.apache.org/viewvc?rev=577683&view=rev
Log:
Don't use System.out

Modified:
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/QueueWorkerPrefetchTest.java

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/QueueWorkerPrefetchTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/QueueWorkerPrefetchTest.java?rev=577683&r1=577682&r2=577683&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/QueueWorkerPrefetchTest.java
(original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/QueueWorkerPrefetchTest.java
Thu Sep 20 04:09:32 2007
@@ -37,12 +37,15 @@
 import org.apache.activemq.ActiveMQConnectionFactory;
 import org.apache.activemq.ActiveMQPrefetchPolicy;
 import org.apache.activemq.broker.BrokerService;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
 
 /**
  * Test case demonstrating situation where messages are not delivered to consumers.
  */
 public class QueueWorkerPrefetchTest extends TestCase implements MessageListener
 {
+	 private static final Log LOG = LogFactory.getLog(QueueWorkerPrefetchTest.class);
     private static final int BATCH_SIZE = 10;
     private static final long WAIT_TIMEOUT = 1000*10;
 
@@ -156,7 +159,7 @@
         long acks = acksReceived.incrementAndGet();
         latch.get().countDown();
         if (acks % 1 == 0) {
-            System.out.println("Master now has ack count of: " + acksReceived);
+            LOG.info("Master now has ack count of: " + acksReceived);
         }
     }
 
@@ -212,7 +215,7 @@
             fail("First batch only received " + acksReceived + " messages");
         }
 
-        System.out.println("First batch received");
+       LOG.info("First batch received");
 
         // Send another message to the work queue, and wait for the next 1000 acks.  It is
         // at this point where the workers never get notified of this message, as they
@@ -226,7 +229,7 @@
             fail("Second batch only received " + acksReceived + " messages");
         }
 
-        System.out.println("Second batch received");
+        LOG.info("Second batch received");
 
         // Cleanup all JMS resources.
         for (int i = 0; i < NUM_WORKERS; i++) {



Mime
View raw message