You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2009/08/06 13:58:52 UTC
svn commit: r801616 - in /camel/sandbox/tuning-experiment/camel-core/src:
main/java/org/apache/camel/component/file/GenericFileProducer.java
test/java/org/apache/camel/processor/RoutePerformanceCountTest.java
Author: davsclaus
Date: Thu Aug 6 11:58:51 2009
New Revision: 801616
URL: http://svn.apache.org/viewvc?rev=801616&view=rev
Log:
Fixed not needed copy in file producer
Modified:
camel/sandbox/tuning-experiment/camel-core/src/main/java/org/apache/camel/component/file/GenericFileProducer.java
camel/sandbox/tuning-experiment/camel-core/src/test/java/org/apache/camel/processor/RoutePerformanceCountTest.java
Modified: camel/sandbox/tuning-experiment/camel-core/src/main/java/org/apache/camel/component/file/GenericFileProducer.java
URL: http://svn.apache.org/viewvc/camel/sandbox/tuning-experiment/camel-core/src/main/java/org/apache/camel/component/file/GenericFileProducer.java?rev=801616&r1=801615&r2=801616&view=diff
==============================================================================
--- camel/sandbox/tuning-experiment/camel-core/src/main/java/org/apache/camel/component/file/GenericFileProducer.java (original)
+++ camel/sandbox/tuning-experiment/camel-core/src/main/java/org/apache/camel/component/file/GenericFileProducer.java Thu Aug 6 11:58:51 2009
@@ -53,18 +53,6 @@
@SuppressWarnings("unchecked")
public void process(Exchange exchange) throws Exception {
- Exchange fileExchange = endpoint.createExchange(exchange);
- processExchange(fileExchange);
- ExchangeHelper.copyResults(exchange, fileExchange);
- }
-
- /**
- * Perform the work to process the fileExchange
- *
- * @param exchange fileExchange
- * @throws Exception is thrown if some error
- */
- protected void processExchange(Exchange exchange) throws Exception {
if (log.isTraceEnabled()) {
log.trace("Processing " + exchange);
}
Modified: camel/sandbox/tuning-experiment/camel-core/src/test/java/org/apache/camel/processor/RoutePerformanceCountTest.java
URL: http://svn.apache.org/viewvc/camel/sandbox/tuning-experiment/camel-core/src/test/java/org/apache/camel/processor/RoutePerformanceCountTest.java?rev=801616&r1=801615&r2=801616&view=diff
==============================================================================
--- camel/sandbox/tuning-experiment/camel-core/src/test/java/org/apache/camel/processor/RoutePerformanceCountTest.java (original)
+++ camel/sandbox/tuning-experiment/camel-core/src/test/java/org/apache/camel/processor/RoutePerformanceCountTest.java Thu Aug 6 11:58:51 2009
@@ -29,7 +29,7 @@
public class RoutePerformanceCountTest extends ContextTestSupport {
private CountProcessor processor = new CountProcessor();
- private int size = 10000;
+ private int size = 50000;
private String url = "direct:start";
public void testSendMessages() throws Exception {