You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by de...@apache.org on 2010/03/30 13:48:02 UTC

svn commit: r929094 - /activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/JmsTimeoutTest.java

Author: dejanb
Date: Tue Mar 30 11:48:02 2010
New Revision: 929094

URL: http://svn.apache.org/viewvc?rev=929094&view=rev
Log:
http://issues.apache.org/activemq/browse/AMQ-2507 - use commons logging

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

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/JmsTimeoutTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/JmsTimeoutTest.java?rev=929094&r1=929093&r2=929094&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/JmsTimeoutTest.java (original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/bugs/JmsTimeoutTest.java Tue Mar 30 11:48:02 2010
@@ -4,7 +4,6 @@ package org.apache.activemq.bugs;
 import java.util.concurrent.atomic.AtomicInteger;
 
 import javax.jms.DeliveryMode;
-import javax.jms.ExceptionListener;
 import javax.jms.JMSException;
 import javax.jms.MessageProducer;
 import javax.jms.ResourceAllocationException;
@@ -14,12 +13,13 @@ import javax.jms.TextMessage;
 import org.apache.activemq.ActiveMQConnection;
 import org.apache.activemq.EmbeddedBrokerTestSupport;
 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 {
 
-		private final static Logger logger = Logger.getLogger( JmsTimeoutTest.class );
+		static final Log LOG = LogFactory.getLog(JmsTimeoutTest.class);
 	
 		private int messageSize=1024*64;
 		private int messageCount=10000;
@@ -40,7 +40,7 @@ public class JmsTimeoutTest extends Embe
 	        Runnable r = new Runnable() {
 	            public void run() {
 	                try {
-	                	logger.info("Sender thread starting");
+	                	LOG.info("Sender thread starting");
 	                    Session session = cx.createSession(false, 1);
 	                    MessageProducer producer = session.createProducer(queue);
 	                    producer.setDeliveryMode(DeliveryMode.PERSISTENT);
@@ -52,7 +52,7 @@ public class JmsTimeoutTest extends Embe
 	                    	// returns but there is no way to know that
 	                    	// the send timed out
 	                    }	  
-	                    logger.info("Done sending..");
+	                    LOG.info("Done sending..");
 	                } catch (JMSException e) {
 	                    e.printStackTrace();
 	                    if (e instanceof ResourceAllocationException) {