camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject 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
Date Thu, 06 Aug 2009 11:58:52 GMT
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 {



Mime
View raw message