Author: ningjiang Date: Tue Feb 15 07:44:40 2011 New Revision: 1070795 URL: http://svn.apache.org/viewvc?rev=1070795&view=rev Log: Fixed the CS errors
Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/model/OnExceptionDefinition.java camel/trunk/components/camel-spring/src/main/java/org/apache/camel/spring/handler/CamelNamespaceHandler.java camel/trunk/components/camel-spring/src/main/java/org/apache/camel/spring/handler/ErrorHandlerDefinitionParser.java camel/trunk/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamConsumer.java Modified: camel/trunk/camel-core/src/main/java/org/apache/camel/model/OnExceptionDefinition.java URL: http://svn.apache.org/viewvc/camel/trunk/camel-core/src/main/java/org/apache/camel/model/OnExceptionDefinition.java?rev=1070795&r1=1070794&r2=1070795&view=diff ============================================================================== --- camel/trunk/camel-core/src/main/java/org/apache/camel/model/OnExceptionDefinition.java (original) +++ camel/trunk/camel-core/src/main/java/org/apache/camel/model/OnExceptionDefinition.java Tue Feb 15 07:44:40 2011 @@ -812,7 +812,7 @@ public class OnExceptionDefinition exten } public boolean isAsyncDelayedRedelivery(CamelContext context) { - if (getRedeliveryPolicy() != null ) { + if (getRedeliveryPolicy() != null) { return getRedeliveryPolicy().isAsyncDelayedRedelivery(context); } return false; Modified: camel/trunk/components/camel-spring/src/main/java/org/apache/camel/spring/handler/CamelNamespaceHandler.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-spring/src/main/java/org/apache/camel/spring/handler/CamelNamespaceHandler.java?rev=1070795&r1=1070794&r2=1070795&view=diff ============================================================================== --- camel/trunk/components/camel-spring/src/main/java/org/apache/camel/spring/handler/CamelNamespaceHandler.java (original) +++ camel/trunk/components/camel-spring/src/main/java/org/apache/camel/spring/handler/CamelNamespaceHandler.java Tue Feb 15 07:44:40 2011 @@ -26,7 +26,6 @@ import javax.xml.bind.Binder; import javax.xml.bind.JAXBContext; import javax.xml.bind.JAXBException; -import org.apache.camel.spring.CamelRedeliveryPolicyFactoryBean; import org.w3c.dom.Document; import org.w3c.dom.Element; import org.w3c.dom.Node; @@ -45,6 +44,7 @@ import org.apache.camel.spring.CamelCons import org.apache.camel.spring.CamelContextFactoryBean; import org.apache.camel.spring.CamelEndpointFactoryBean; import org.apache.camel.spring.CamelProducerTemplateFactoryBean; +import org.apache.camel.spring.CamelRedeliveryPolicyFactoryBean; import org.apache.camel.spring.CamelRouteContextFactoryBean; import org.apache.camel.spring.CamelThreadPoolFactoryBean; import org.apache.camel.spring.remoting.CamelProxyFactoryBean; @@ -62,6 +62,7 @@ import org.springframework.beans.factory import org.springframework.beans.factory.xml.NamespaceHandlerSupport; import org.springframework.beans.factory.xml.ParserContext; + /** * Camel namespace for the spring XML configuration file. */ Modified: camel/trunk/components/camel-spring/src/main/java/org/apache/camel/spring/handler/ErrorHandlerDefinitionParser.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-spring/src/main/java/org/apache/camel/spring/handler/ErrorHandlerDefinitionParser.java?rev=1070795&r1=1070794&r2=1070795&view=diff ============================================================================== --- camel/trunk/components/camel-spring/src/main/java/org/apache/camel/spring/handler/ErrorHandlerDefinitionParser.java (original) +++ camel/trunk/components/camel-spring/src/main/java/org/apache/camel/spring/handler/ErrorHandlerDefinitionParser.java Tue Feb 15 07:44:40 2011 @@ -55,8 +55,10 @@ public class ErrorHandlerDefinitionParse if (attributeName == null || ID_ATTRIBUTE.equals(attributeName)) { return false; } - return !attributeName.equals("xmlns") && !attributeName.startsWith("xmlns:") - && !attributeName.equals("type") + if (attributeName.equals("xmlns") || attributeName.startsWith("xmlns:")) { + return false; + } + return !attributeName.equals("type") && !attributeName.equals("onRedeliveryRef") && !attributeName.equals("onRetryWhileRef") && !attributeName.equals("redeliveryPolicyRef") Modified: camel/trunk/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamConsumer.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamConsumer.java?rev=1070795&r1=1070794&r2=1070795&view=diff ============================================================================== --- camel/trunk/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamConsumer.java (original) +++ camel/trunk/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamConsumer.java Tue Feb 15 07:44:40 2011 @@ -124,7 +124,7 @@ public class StreamConsumer extends Defa boolean eos = line == null; if (!eos && isRunAllowed()) { processLine(line); - } else if (eos && isRunAllowed() && endpoint.isRetry() ) { + } else if (eos && isRunAllowed() && endpoint.isRetry()) { //try and re-open stream br = initializeStream(); }