You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2011/12/22 15:23:26 UTC
svn commit: r1222250 -
/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ActiveMQMessageAuditTest.java
Author: tabish
Date: Thu Dec 22 14:23:25 2011
New Revision: 1222250
URL: http://svn.apache.org/viewvc?rev=1222250&view=rev
Log:
Replace the System.out calls with loggers.
Modified:
activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ActiveMQMessageAuditTest.java
Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ActiveMQMessageAuditTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ActiveMQMessageAuditTest.java?rev=1222250&r1=1222249&r2=1222250&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ActiveMQMessageAuditTest.java (original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/ActiveMQMessageAuditTest.java Thu Dec 22 14:23:25 2011
@@ -28,18 +28,21 @@ import org.apache.activemq.command.Activ
import org.apache.activemq.command.MessageId;
import org.apache.activemq.command.ProducerId;
import org.apache.activemq.util.IdGenerator;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
/**
* ActiveMQMessageAuditTest
- *
- *
+ *
+ *
*/
public class ActiveMQMessageAuditTest extends TestCase {
+ static final Logger LOG = LoggerFactory.getLogger(ActiveMQMessageAuditTest.class);
/**
* Constructor for ActiveMQMessageAuditTest.
- *
+ *
* @param name
*/
public ActiveMQMessageAuditTest(String name) {
@@ -100,7 +103,7 @@ public class ActiveMQMessageAuditTest ex
assertTrue("duplicate msg:" + msg, audit.isDuplicate(msg));
}
}
-
+
public void testIsInOrderString() {
int count = 10000;
ActiveMQMessageAudit audit = new ActiveMQMessageAudit();
@@ -116,7 +119,7 @@ public class ActiveMQMessageAuditTest ex
if (i > 1 && i%2 != 0) {
list.add(id);
}
-
+
}
for (String id : list) {
assertFalse(audit.isInOrder(id));
@@ -128,18 +131,17 @@ public class ActiveMQMessageAuditTest ex
ActiveMQMessageAuditNoSync audit = new ActiveMQMessageAuditNoSync();
byte[] bytes = serialize(audit);
- System.out.println(bytes.length);
+ LOG.debug("Length: " + bytes.length);
audit = recover(bytes);
List<MessageReference> list = new ArrayList<MessageReference>();
-
for (int j = 0; j < 1000; j++) {
ProducerId pid = new ProducerId();
pid.setConnectionId("test");
pid.setSessionId(0);
pid.setValue(j);
- System.out.println("producer " + j);
+ LOG.debug("producer " + j);
for (int i = 0; i < 1000; i++) {
MessageId id = new MessageId();
@@ -152,7 +154,7 @@ public class ActiveMQMessageAuditTest ex
if (i % 100 == 0) {
bytes = serialize(audit);
- System.out.println(bytes.length);
+ LOG.debug("Length: " + bytes.length);
audit = recover(bytes);
}
@@ -162,13 +164,11 @@ public class ActiveMQMessageAuditTest ex
}
list.clear();
bytes = serialize(audit);
- System.out.println(bytes.length);
+ LOG.debug("Length: " + bytes.length);
audit = recover(bytes);
}
-
}
}
-
}
protected byte[] serialize(ActiveMQMessageAuditNoSync audit) throws Exception {