Java 类org.apache.camel.http.common.HttpOperationFailedException 实例源码

项目：Camel 文件：HttpRedirectTest.java

@Test
public void httpRedirect() throws Exception {

    String uri = "http4://" + localServer.getInetAddress().getHostName() + ":" + localServer.getLocalPort()
            + "/test?httpClient.redirectsEnabled=false&httpClient.socketTimeout=60000&httpClient.connectTimeout=60000"
            + "&httpClient.staleConnectionCheckEnabled=false";
    Exchange out = template.request(uri, new Processor() {
        public void process(Exchange exchange) throws Exception {
            // no data
        }
    });

    assertNotNull(out);
    HttpOperationFailedException cause = out.getException(HttpOperationFailedException.class);
    assertNotNull(cause);
    assertEquals(HttpStatus.SC_MOVED_PERMANENTLY, cause.getStatusCode());
    assertEquals("http4://" + localServer.getInetAddress().getHostName() + ":" + localServer.getLocalPort() + "/someplaceelse", cause.getRedirectLocation());
}

项目：Camel 文件：RestRestletPostJsonPojoOnExceptionTest.java

@Test
public void testRestletPostPojoError() throws Exception {
    getMockEndpoint("mock:input").expectedMessageCount(0);
    getMockEndpoint("mock:error").expectedMessageCount(1);

    String body = "This is not json";
    try {
        template.sendBody("http://localhost:" + portNum + "/users/new", body);
        fail("Should have thrown an exception");
    } catch (CamelExecutionException e) {
        HttpOperationFailedException cause = assertIsInstanceOf(HttpOperationFailedException.class, e.getCause());
        assertEquals(400, cause.getStatusCode());
        assertEquals("Invalid json data", cause.getResponseBody());
    }

    assertMockEndpointsSatisfied();
}

项目：Camel 文件：JettyResponseBodyWhenErrorTest.java

@Test
public void testResponseBodyWhenError() throws Exception {
    try {
        template.requestBody("http://localhost:{{port}}/myapp/myservice", "bookid=123");
        fail("Should have thrown an exception");
    } catch (RuntimeCamelException e) {
        HttpOperationFailedException cause = assertIsInstanceOf(HttpOperationFailedException.class, e.getCause());
        assertEquals(500, cause.getStatusCode());
        String body = context.getTypeConverter().convertTo(String.class, cause.getResponseBody());
        assertTrue(body.indexOf("Damm") > -1);
        assertTrue(body.indexOf("IllegalArgumentException") > -1);
        assertNotNull(cause.getResponseHeaders());
        String type = cause.getResponseHeaders().get(Exchange.CONTENT_TYPE);
        assertTrue(type.startsWith("text/plain"));
    }
}

项目：Camel 文件：JettyHttpProducerSimulate404ErrorTest.java

@Test
public void test404() throws Exception {
    // give Jetty time to startup properly
    Thread.sleep(1000);

    try {
        template.sendBody(url, null);
        fail("Should have thrown exception");
    } catch (Exception e) {
        HttpOperationFailedException cause = assertIsInstanceOf(HttpOperationFailedException.class, e.getCause());
        assertEquals(404, cause.getStatusCode());
        assertEquals("http://127.0.0.1:" + getPort() + "/bar", cause.getUri());
        assertEquals("Page not found", cause.getResponseBody());
        assertNotNull(cause.getResponseHeaders());
    }
}

项目：Camel 文件：HttpStreamCacheFileTest.java

@Test
public void testStreamCacheToFileShouldBeDeletedInCaseOfException() throws Exception {
    try {
        template.requestBody("direct:start", null, String.class);
        fail("Should have thrown an exception");
    } catch (CamelExecutionException e) {
        HttpOperationFailedException hofe = assertIsInstanceOf(HttpOperationFailedException.class, e.getCause());
        String s = context.getTypeConverter().convertTo(String.class, hofe.getResponseBody());
        assertEquals("Response body", responseBody, s);
    }

    // the temporary files should have been deleted
    File file = new File("target/cachedir");
    String[] files = file.list();
    assertEquals("There should be no files", 0, files.length);
}

项目：Camel 文件：HttpRedirectTest.java

@Test
public void testHttpRedirectFromCamelRoute() throws Exception {
    MockEndpoint errorEndpoint = context.getEndpoint("mock:error", MockEndpoint.class);
    errorEndpoint.expectedMessageCount(1);
    MockEndpoint resultEndpoint = context.getEndpoint("mock:result", MockEndpoint.class);
    resultEndpoint.expectedMessageCount(0);
    try {
        template.requestBody("direct:start", "Hello World", String.class);
        fail("Should have thrown an exception");
    } catch (RuntimeCamelException e) {
        HttpOperationFailedException cause = assertIsInstanceOf(HttpOperationFailedException.class,
                                                                e.getCause());
        assertEquals(302, cause.getStatusCode());
    }
    errorEndpoint.assertIsSatisfied();
    resultEndpoint.assertIsSatisfied();
}

项目：Camel 文件：JettySuspendTest.java

@Test
public void testJettySuspend() throws Exception {
    context.getShutdownStrategy().setTimeout(50);

    String reply = template.requestBody(serverUri, "World", String.class);
    assertEquals("Bye World", reply);

    // now suspend jetty
    HttpConsumer consumer = (HttpConsumer) context.getRoute("route1").getConsumer();
    assertNotNull(consumer);

    // suspend
    consumer.suspend();

    try {
        template.requestBody(serverUri, "Moon", String.class);
        fail("Should throw exception");
    } catch (Exception e) {
        HttpOperationFailedException cause = assertIsInstanceOf(HttpOperationFailedException.class, e.getCause());
        assertEquals(503, cause.getStatusCode());
    }
}

项目：Camel 文件：JettyAsyncContinuationTimeoutTest.java

@Test
public void testJettyAsyncTimeout() throws Exception {
    getMockEndpoint("mock:result").expectedBodiesReceived("Bye World");

    StopWatch watch = new StopWatch();
    try {
        template.requestBody("http://localhost:{{port}}/myservice", null, String.class);
        fail("Should have thrown an exception");
    } catch (CamelExecutionException e) {
        log.info("Timeout hit and client got reply with failure status code");

        long taken = watch.stop();

        HttpOperationFailedException cause = assertIsInstanceOf(HttpOperationFailedException.class, e.getCause());
        assertEquals(503, cause.getStatusCode());

        // should be approx 3-4 sec.
        assertTrue("Timeout should occur faster than " + taken, taken < 4500);
    }

    assertMockEndpointsSatisfied();
}

项目：Camel 文件：JettyAsyncDefaultContinuationTimeoutTest.java

@Test
public void testJettyAsyncTimeout() throws Exception {
    getMockEndpoint("mock:result").expectedBodiesReceived("Bye World");

    StopWatch watch = new StopWatch();
    try {
        template.requestBody("http://localhost:{{port}}/myservice", null, String.class);
        fail("Should have thrown an exception");
    } catch (CamelExecutionException e) {
        log.info("Timeout hit and client got reply with failure status code");

        long taken = watch.stop();

        HttpOperationFailedException cause = assertIsInstanceOf(HttpOperationFailedException.class, e.getCause());
        assertEquals(503, cause.getStatusCode());

        // should be approx 30-34 sec.
        assertTrue("Timeout should occur faster than " + taken, taken < 34000);
    }

    assertMockEndpointsSatisfied(2, TimeUnit.MINUTES);
}