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/

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

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/

ningjiang
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();
         }