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/06/28 18:06:55 UTC
svn commit: r789118 - in /camel/trunk/components:
camel-jaxb/src/test/java/org/apache/camel/example/
camel-stream/src/main/java/org/apache/camel/component/stream/
camel-stream/src/test/java/org/apache/camel/component/stream/
Author: ningjiang
Date: Sun Jun 28 16:06:54 2009
New Revision: 789118
URL: http://svn.apache.org/viewvc?rev=789118&view=rev
Log:
Fixed the cs errors in camel components
Modified:
camel/trunk/components/camel-jaxb/src/test/java/org/apache/camel/example/RouteWithErrorHandlerTest.java
camel/trunk/components/camel-stream/src/main/java/org/apache/camel/component/stream/StreamConsumer.java
camel/trunk/components/camel-stream/src/test/java/org/apache/camel/component/stream/ScanStreamFileWithFilterTest.java
Modified: camel/trunk/components/camel-jaxb/src/test/java/org/apache/camel/example/RouteWithErrorHandlerTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jaxb/src/test/java/org/apache/camel/example/RouteWithErrorHandlerTest.java?rev=789118&r1=789117&r2=789118&view=diff
==============================================================================
--- camel/trunk/components/camel-jaxb/src/test/java/org/apache/camel/example/RouteWithErrorHandlerTest.java (original)
+++ camel/trunk/components/camel-jaxb/src/test/java/org/apache/camel/example/RouteWithErrorHandlerTest.java Sun Jun 28 16:06:54 2009
@@ -82,10 +82,10 @@
from("direct:start")
.unmarshal(jaxb)
- .choice()
- .when().method(RouteWithErrorHandlerTest.class, "isWine").to("mock:wine")
- .otherwise().throwException(new InvalidOrderException("We only like wine"))
- .end();
+ .choice()
+ .when().method(RouteWithErrorHandlerTest.class, "isWine").to("mock:wine")
+ .otherwise().throwException(new InvalidOrderException("We only like wine"))
+ .end();
}
};
}
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=789118&r1=789117&r2=789118&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 Sun Jun 28 16:06:54 2009
@@ -80,11 +80,12 @@
@Override
public void doStop() throws Exception {
- // important: do not close the stream as it will close the standard system.in etc.
- ObjectHelper.notNull(executor, "Executor");
- executor.shutdownNow();
- executor = null;
- super.doStop();
+ // important: do not close the stream as it will close the standard
+ // system.in etc.
+ ObjectHelper.notNull(executor, "Executor");
+ executor.shutdownNow();
+ executor = null;
+ super.doStop();
}
public void run() {
@@ -197,13 +198,13 @@
File file = new File(fileName);
if (LOG.isDebugEnabled()) {
- LOG.debug("File to be scanned : " + file.getName() + ", path : " + file.getAbsolutePath());
+ LOG.debug("File to be scanned : " + file.getName() + ", path : " + file.getAbsolutePath());
}
- if ( file.canRead() ) {
- fileStream = new FileInputStream(file);
+ if (file.canRead()) {
+ fileStream = new FileInputStream(file);
} else {
- throw new IllegalArgumentException(INVALID_URI);
+ throw new IllegalArgumentException(INVALID_URI);
}
return fileStream;
Modified: camel/trunk/components/camel-stream/src/test/java/org/apache/camel/component/stream/ScanStreamFileWithFilterTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-stream/src/test/java/org/apache/camel/component/stream/ScanStreamFileWithFilterTest.java?rev=789118&r1=789117&r2=789118&view=diff
==============================================================================
--- camel/trunk/components/camel-stream/src/test/java/org/apache/camel/component/stream/ScanStreamFileWithFilterTest.java (original)
+++ camel/trunk/components/camel-stream/src/test/java/org/apache/camel/component/stream/ScanStreamFileWithFilterTest.java Sun Jun 28 16:06:54 2009
@@ -76,8 +76,8 @@
return new RouteBuilder() {
public void configure() {
from("stream:file?fileName=./target/stream/scanstreamfile.txt&scanStream=true&scanStreamDelay=100")
- .filter(body().contains("Hello Boy"))
- .to("mock:result");
+ .filter(body().contains("Hello Boy"))
+ .to("mock:result");
}
};
}