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 2013/04/22 12:20:11 UTC
svn commit: r1470431 -
/camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/MultiThreadedHttpGetTest.java
Author: ningjiang
Date: Mon Apr 22 10:20:11 2013
New Revision: 1470431
URL: http://svn.apache.org/r1470431
Log:
CAMEL-6296 fixed the test error of camel-jetty
Modified:
camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/MultiThreadedHttpGetTest.java
Modified: camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/MultiThreadedHttpGetTest.java
URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/MultiThreadedHttpGetTest.java?rev=1470431&r1=1470430&r2=1470431&view=diff
==============================================================================
--- camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/MultiThreadedHttpGetTest.java (original)
+++ camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/MultiThreadedHttpGetTest.java Mon Apr 22 10:20:11 2013
@@ -24,6 +24,8 @@ import org.apache.camel.Processor;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.http.HttpComponent;
import org.apache.camel.component.mock.MockEndpoint;
+import org.apache.commons.httpclient.HttpConnectionManager;
+import org.apache.commons.httpclient.MultiThreadedHttpConnectionManager;
import org.junit.Test;
/**
@@ -48,9 +50,11 @@ public class MultiThreadedHttpGetTest ex
// This is needed as by default there are 2 parallel
// connections to some host and there is nothing that
// closes the http connection here.
-
- context.getComponent("http", HttpComponent.class).getHttpConnectionManager().getParams()
- .setDefaultMaxConnectionsPerHost(5);
+ // Need to set the httpConnectionManager
+ HttpConnectionManager httpConnectionManager = new MultiThreadedHttpConnectionManager();
+ httpConnectionManager.getParams().setDefaultMaxConnectionsPerHost(5);
+ context.getComponent("http", HttpComponent.class).setHttpConnectionManager(httpConnectionManager);
+
String endpointName = "seda:withoutConversion?concurrentConsumers=5";
sendMessagesTo(endpointName, 5);