Advertisement
Guest User

Untitled

a guest
Dec 17th, 2012
93
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 2.49 KB | None | 0 0
  1. package testIntercept;
  2.  
  3. import org.apache.camel.Exchange;
  4. import org.apache.camel.Processor;
  5. import org.apache.camel.builder.AdviceWithRouteBuilder;
  6. import org.apache.camel.builder.RouteBuilder;
  7. import org.apache.camel.test.junit4.CamelTestSupport;
  8. import org.junit.Assert;
  9. import org.junit.Test;
  10.  
  11. public class TestHTTP4WithParameter extends CamelTestSupport {
  12.  
  13. private String simpleProvider = "http4:fakeHTTPADDRESS.com:80?throwExceptionOnFailure=false";
  14. private String providerWithParameter = "http4:fakeHTTPADDRESS.com:80?throwExceptionOnFailure=false&httpClient.cookiePolicy=ignoreCookies";
  15. private boolean messageIntercepted;
  16.  
  17. @Test
  18. public void testHttp4WithoutHttpClientParameter() throws Exception {
  19. doTestHttp4Parameter(simpleProvider);
  20. }
  21.  
  22. /**
  23. * This test will fail even if the message is never received by the Endpoint.
  24. * @throws Exception
  25. */
  26. @Test
  27. public void testHttp4WithHttpClientParameter() throws Exception {
  28. doTestHttp4Parameter(providerWithParameter);
  29. }
  30.  
  31. public void doTestHttp4Parameter(final String provider) throws Exception {
  32.  
  33. messageIntercepted = false;
  34.  
  35. context.addRoutes(new RouteBuilder() {
  36. @Override
  37. public void configure() throws Exception {
  38.  
  39. from("direct:start")
  40. .to(provider)
  41. .to("mock:result");
  42. }
  43. });
  44.  
  45. context.getRouteDefinitions().get(0).adviceWith(context, new AdviceWithRouteBuilder() {
  46. @Override
  47. public void configure() throws Exception {
  48.  
  49. interceptSendToEndpoint(simpleProvider)
  50. .skipSendToOriginalEndpoint()
  51. .process(new Processor() {
  52. @Override
  53. public void process(Exchange exchange) throws Exception {
  54. messageIntercepted = true;
  55. }
  56. })
  57. .to("mock:advised");
  58. }
  59. });
  60.  
  61. context.start();
  62.  
  63. getMockEndpoint("mock:advised").expectedMessageCount(1);
  64. getMockEndpoint("mock:result").expectedMessageCount(1);
  65.  
  66. template.sendBody("direct:start", "Hello World");
  67.  
  68. assertMockEndpointsSatisfied();
  69.  
  70. Assert.assertTrue(messageIntercepted);
  71. }
  72.  
  73. @Override
  74. public boolean isUseRouteBuilder() {
  75. return false;
  76. }
  77. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement