Author: davsclaus Date: Fri Jun 3 13:42:19 2011 New Revision: 1131036 URL: http://svn.apache.org/viewvc?rev=1131036&view=rev Log: CAMEL-2525: wiki example
Modified: camel/trunk/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentClientConfigTest.java Modified: camel/trunk/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentClientConfigTest.java URL: http://svn.apache.org/viewvc/camel/trunk/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentClientConfigTest.java?rev=1131036&r1=1131035&r2=1131036&view=diff ============================================================================== --- camel/trunk/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentClientConfigTest.java (original) +++ camel/trunk/components/camel-ahc/src/test/java/org/apache/camel/component/ahc/AhcComponentClientConfigTest.java Fri Jun 3 13:42:19 2011 @@ -26,14 +26,24 @@ import org.junit.Test; public class AhcComponentClientConfigTest extends CamelTestSupport { - @Override - protected CamelContext createCamelContext() throws Exception { + public void configureComponent() { + // START SNIPPET: e1 + // create a client config builder AsyncHttpClientConfig.Builder builder = new AsyncHttpClientConfig.Builder(); + // use the builder to set the options we want, in this case we want to follow redirects and try + // at most 3 retries to send a request to the host AsyncHttpClientConfig config = builder.setFollowRedirects(true).setMaxRequestRetry(3).build(); - CamelContext context = super.createCamelContext(); + // lookup AhcComponent AhcComponent component = context.getComponent("ahc", AhcComponent.class); + // and set our custom client config to be used component.setClientConfig(config); + // END SNIPPET: e1 + } + + @Override + protected CamelContext createCamelContext() throws Exception { + CamelContext context = super.createCamelContext(); return context; } @@ -51,6 +61,8 @@ public class AhcComponentClientConfigTes return new RouteBuilder() { @Override public void configure() throws Exception { + configureComponent(); + from("direct:start") .to("ahc:http://localhost:9080/foo") .to("mock:result");