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 2011/02/15 08:44:41 UTC
svn commit: r1070795 - in /camel/trunk:
camel-core/src/main/java/org/apache/camel/model/
components/camel-spring/src/main/java/org/apache/camel/spring/handler/
components/camel-stream/src/main/java/org/apache/camel/component/stream/
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();
}