You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ra...@apache.org on 2007/09/20 13:09:32 UTC
svn commit: r577683 -
/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/QueueWorkerPrefetchTest.java
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++) {