camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ningji...@apache.org
Subject svn commit: r772055 - in /camel/trunk/components: camel-jms/src/test/java/org/apache/camel/component/jms/issues/ camel-ldap/src/main/java/org/apache/camel/component/ldap/
Date Wed, 06 May 2009 05:15:30 GMT
Author: ningjiang
Date: Wed May  6 05:15:30 2009
New Revision: 772055

URL: http://svn.apache.org/viewvc?rev=772055&view=rev
Log:
Fixed the cs errors in the camel component

Modified:
    camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsHammerTest.java
    camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsMessageHeaderContentBasedRouterTest.java
    camel/trunk/components/camel-ldap/src/main/java/org/apache/camel/component/ldap/LdapProducer.java

Modified: camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsHammerTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsHammerTest.java?rev=772055&r1=772054&r2=772055&view=diff
==============================================================================
--- camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsHammerTest.java
(original)
+++ camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsHammerTest.java
Wed May  6 05:15:30 2009
@@ -32,25 +32,28 @@
  */
 public class JmsHammerTest extends ContextTestSupport {
 
-    private static Log LOG = LogFactory.getLog(JmsHammerTest.class);
+    private static final Log LOG = LogFactory.getLog(JmsHammerTest.class);
 
-	private String message;
+    private String message;
     // TODO: AMQ reaches a limit when sending #169.
     // private int size = 200;
     private int size = 10;
 
     public void prepareMessage() throws Exception {
-		StringBuffer sb = new StringBuffer();
-		for (int i = 0; i < 20000; i++) {
-			sb.append("hellothere");
-		}
-		message = sb.toString();
-	}
+        StringBuffer sb = new StringBuffer();
+        for (int i = 0; i < 20000; i++) {
+            sb.append("hellothere");
+        }
+        message = sb.toString();
+    }
 
     protected CamelContext createCamelContext() throws Exception {
         CamelContext camelContext = super.createCamelContext();
         // TODO: MR-170
-        ActiveMQComponent activemq = activeMQComponent("vm://localhost?broker.persistent=false&broker.useJmx=false&jms.redeliveryPolicy.maximumRedeliveries=0&jms.redeliveryPolicy.initialRedeliveryDelay=500&jms.useAsyncSend=false&jms.sendTimeout=10000&jms.maxReconnectAttempts=1&jms.timeout=3000");
+        ActiveMQComponent activemq = 
+            activeMQComponent("vm://localhost?broker.persistent=false&broker.useJmx=false&jms.redeliveryPolicy.maximumRedeliveries=0"

+                              + "&jms.redeliveryPolicy.initialRedeliveryDelay=500&jms.useAsyncSend=false&jms.sendTimeout=10000"
+                              + "&jms.maxReconnectAttempts=1&jms.timeout=3000");
         camelContext.addComponent("activemq", activemq);
         return camelContext;
     }

Modified: camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsMessageHeaderContentBasedRouterTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsMessageHeaderContentBasedRouterTest.java?rev=772055&r1=772054&r2=772055&view=diff
==============================================================================
--- camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsMessageHeaderContentBasedRouterTest.java
(original)
+++ camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/issues/JmsMessageHeaderContentBasedRouterTest.java
Wed May  6 05:15:30 2009
@@ -65,8 +65,8 @@
     }
 
     public static class MyPreProcessorBean {
-
-        public static void determineRouting(Exchange exchange) {
+        
+        public void determineRouting(Exchange exchange) {
             exchange.getIn().setHeader("route", "b");
         }
     }

Modified: camel/trunk/components/camel-ldap/src/main/java/org/apache/camel/component/ldap/LdapProducer.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-ldap/src/main/java/org/apache/camel/component/ldap/LdapProducer.java?rev=772055&r1=772054&r2=772055&view=diff
==============================================================================
--- camel/trunk/components/camel-ldap/src/main/java/org/apache/camel/component/ldap/LdapProducer.java
(original)
+++ camel/trunk/components/camel-ldap/src/main/java/org/apache/camel/component/ldap/LdapProducer.java
Wed May  6 05:15:30 2009
@@ -55,14 +55,15 @@
         // classes will require prototype scope though.
         DirContext ldapContext = (DirContext)getEndpoint().getCamelContext().getRegistry().lookup(remaining);
         try {
-	        // could throw NamingException
-	        List<SearchResult> data = new ArrayList<SearchResult>();
-	        NamingEnumeration<SearchResult> namingEnumeration = ldapContext.search(searchBase,
filter, getControls());
+            // could throw NamingException
+            List<SearchResult> data = new ArrayList<SearchResult>();
+            NamingEnumeration<SearchResult> namingEnumeration = ldapContext.search(searchBase,
filter,
+                                                                                   getControls());
 
-	        while (namingEnumeration.hasMore()) {
-	            data.add(namingEnumeration.next());
-	        }
-	        exchange.getOut().setBody(data);
+            while (namingEnumeration.hasMore()) {
+                data.add(namingEnumeration.next());
+            }
+            exchange.getOut().setBody(data);
         } finally {
             ldapContext.close();
         }



Mime
View raw message