You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ni...@apache.org on 2009/05/06 07:15:30 UTC
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/
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();
}