Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package testIntercept;
- import org.apache.camel.Exchange;
- import org.apache.camel.Processor;
- import org.apache.camel.builder.AdviceWithRouteBuilder;
- import org.apache.camel.builder.RouteBuilder;
- import org.apache.camel.test.junit4.CamelTestSupport;
- import org.junit.Assert;
- import org.junit.Test;
- public class TestHTTP4WithParameter extends CamelTestSupport {
- private String simpleProvider = "http4:fakeHTTPADDRESS.com:80?throwExceptionOnFailure=false";
- private String providerWithParameter = "http4:fakeHTTPADDRESS.com:80?throwExceptionOnFailure=false&httpClient.cookiePolicy=ignoreCookies";
- private boolean messageIntercepted;
- @Test
- public void testHttp4WithoutHttpClientParameter() throws Exception {
- doTestHttp4Parameter(simpleProvider);
- }
- /**
- * This test will fail even if the message is never received by the Endpoint.
- * @throws Exception
- */
- @Test
- public void testHttp4WithHttpClientParameter() throws Exception {
- doTestHttp4Parameter(providerWithParameter);
- }
- public void doTestHttp4Parameter(final String provider) throws Exception {
- messageIntercepted = false;
- context.addRoutes(new RouteBuilder() {
- @Override
- public void configure() throws Exception {
- from("direct:start")
- .to(provider)
- .to("mock:result");
- }
- });
- context.getRouteDefinitions().get(0).adviceWith(context, new AdviceWithRouteBuilder() {
- @Override
- public void configure() throws Exception {
- interceptSendToEndpoint(simpleProvider)
- .skipSendToOriginalEndpoint()
- .process(new Processor() {
- @Override
- public void process(Exchange exchange) throws Exception {
- messageIntercepted = true;
- }
- })
- .to("mock:advised");
- }
- });
- context.start();
- getMockEndpoint("mock:advised").expectedMessageCount(1);
- getMockEndpoint("mock:result").expectedMessageCount(1);
- template.sendBody("direct:start", "Hello World");
- assertMockEndpointsSatisfied();
- Assert.assertTrue(messageIntercepted);
- }
- @Override
- public boolean isUseRouteBuilder() {
- return false;
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement