svn commit: r1470431 - /camel/trunk/components/camel-jetty/src/test/java/org/apache/camel/component/jetty/MultiThreadedHttpGetTest.java

[ningjiang]

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);