Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

http://issues.apache.org/activemq/browse/AMQ-2507 - use commons logging 

git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@929094 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Bosanac Dejan 2010-03-30 11:48:02 +00:00
parent 55be01fb55
commit 99d51265ff
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
activemq-core/src/test/java/org/apache/activemq/bugs/JmsTimeoutTest.java
View File

@ -4,7 +4,6 @@ package org.apache.activemq.bugs;
import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicInteger;
import javax.jms.DeliveryMode; import javax.jms.DeliveryMode;
import javax.jms.ExceptionListener;
import javax.jms.JMSException; import javax.jms.JMSException;
import javax.jms.MessageProducer; import javax.jms.MessageProducer;
import javax.jms.ResourceAllocationException; import javax.jms.ResourceAllocationException;
@ -14,12 +13,13 @@ import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnection; import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.EmbeddedBrokerTestSupport; import org.apache.activemq.EmbeddedBrokerTestSupport;
import org.apache.activemq.command.ActiveMQDestination; import org.apache.activemq.command.ActiveMQDestination;
import org.apache.log4j.Logger; import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
public class JmsTimeoutTest extends EmbeddedBrokerTestSupport { public class JmsTimeoutTest extends EmbeddedBrokerTestSupport {
private final static Logger logger = Logger.getLogger( JmsTimeoutTest.class ); static final Log LOG = LogFactory.getLog(JmsTimeoutTest.class);
private int messageSize=1024*64; private int messageSize=1024*64;
private int messageCount=10000; private int messageCount=10000;
@ -40,7 +40,7 @@ public class JmsTimeoutTest extends EmbeddedBrokerTestSupport {
Runnable r = new Runnable() { Runnable r = new Runnable() {
public void run() { public void run() {
try { try {
logger.info("Sender thread starting"); LOG.info("Sender thread starting");
Session session = cx.createSession(false, 1); Session session = cx.createSession(false, 1);
MessageProducer producer = session.createProducer(queue); MessageProducer producer = session.createProducer(queue);
producer.setDeliveryMode(DeliveryMode.PERSISTENT); producer.setDeliveryMode(DeliveryMode.PERSISTENT);
@ -52,7 +52,7 @@ public class JmsTimeoutTest extends EmbeddedBrokerTestSupport {
// returns but there is no way to know that // returns but there is no way to know that
// the send timed out // the send timed out
} }
logger.info("Done sending.."); LOG.info("Done sending..");
} catch (JMSException e) { } catch (JMSException e) {
e.printStackTrace(); e.printStackTrace();
if (e instanceof ResourceAllocationException) { if (e instanceof ResourceAllocationException) {