svn commit: r563930 - in /activemq/trunk/activemq-core/src/test/java/org/apache/activemq: camel/CamelJmsTest.java usecases/AMQFailoverIssue.java

[ch...@apache.org]

Author: chirino
Date: Wed Aug  8 09:30:17 2007
New Revision: 563930

URL: http://svn.apache.org/viewvc?view=rev&rev=563930
Log:
Fixing checkstyle issues

Modified:
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/camel/CamelJmsTest.java
    activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/AMQFailoverIssue.java

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/camel/CamelJmsTest.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/camel/CamelJmsTest.java?view=diff&rev=563930&r1=563929&r2=563930
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/camel/CamelJmsTest.java (original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/camel/CamelJmsTest.java Wed Aug  8 09:30:17 2007
@@ -17,9 +17,12 @@
 package org.apache.activemq.camel;
 
 import junit.framework.Assert;
+import org.apache.activemq.demo.DefaultQueueSender;
 import org.apache.camel.CamelTemplate;
 import org.apache.camel.component.mock.MockEndpoint;
 import org.apache.camel.spring.SpringTestSupport;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
 import org.springframework.context.support.ClassPathXmlApplicationContext;
 
 import javax.jms.Connection;
@@ -36,6 +39,9 @@
  * @version $Revision: $
  */
 public class CamelJmsTest extends SpringTestSupport {
+    
+    private static final Log LOG = LogFactory.getLog(CamelJmsTest.class);
+    
     protected String expectedBody = "<hello>world!</hello>";
 
     public void testSendingViaJmsIsReceivedByCamel() throws Exception {
@@ -59,7 +65,7 @@
 
         result.assertIsSatisfied();
 
-        log.info("Received message: " + result.getReceivedExchanges());
+        LOG.info("Received message: " + result.getReceivedExchanges());
     }
 
     public void testConsumingViaJMSReceivesMessageFromCamel() throws Exception {
@@ -72,7 +78,7 @@
         connection.start();
         Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
 
-        log.info("Consuming from: " + destination);
+        LOG.info("Consuming from: " + destination);
         MessageConsumer consumer = session.createConsumer(destination);
 
         // now lets send a message
@@ -84,7 +90,7 @@
         TextMessage textMessage = assertIsInstanceOf(TextMessage.class, message);
         Assert.assertEquals("Message body", expectedBody, textMessage.getText());
 
-        log.info("Received message: " + message);
+        LOG.info("Received message: " + message);
     }
 
     protected int getExpectedRouteCount() {

Modified: activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/AMQFailoverIssue.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/AMQFailoverIssue.java?view=diff&rev=563930&r1=563929&r2=563930
==============================================================================
--- activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/AMQFailoverIssue.java (original)
+++ activemq/trunk/activemq-core/src/test/java/org/apache/activemq/usecases/AMQFailoverIssue.java Wed Aug  8 09:30:17 2007
@@ -66,7 +66,7 @@
 
     // This should fail with incubator-activemq-fuse-4.1.0.5
     public void testFailoverIssue() throws Exception {
-        BrokerService brokerService1;
+        BrokerService brokerService1=null;
         ActiveMQConnectionFactory acf;
         PooledConnectionFactory pcf;
         DefaultMessageListenerContainer container1 = null;