Java 类org.apache.camel.ResolveEndpointFailedException 实例源码

项目：beyondj 文件：JettyHttpEndpoint.java

protected HttpClient createJettyHttpClient() throws Exception {
    // create a new client
    // thread pool min/max from endpoint take precedence over from component
    Integer min = httpClientMinThreads != null ? httpClientMinThreads : getComponent().getHttpClientMinThreads();
    Integer max = httpClientMaxThreads != null ? httpClientMaxThreads : getComponent().getHttpClientMaxThreads();
    HttpClient httpClient = getComponent().createHttpClient(this, min, max, sslContextParameters);

    // set optional http client parameters
    if (httpClientParameters != null) {
        // copy parameters as we need to re-use them again if creating a new producer later
        Map<String, Object> params = new HashMap<String, Object>(httpClientParameters);
        // Can not be set on httpClient for jetty 9
        params.remove("timeout");
        IntrospectionSupport.setProperties(httpClient, params);
        // validate we could set all parameters
        if (params.size() > 0) {
            throw new ResolveEndpointFailedException(getEndpointUri(), "There are " + params.size()
                    + " parameters that couldn't be set on the endpoint."
                    + " Check the uri if the parameters are spelt correctly and that they are properties of the endpoint."
                    + " Unknown parameters=[" + params + "]");
        }
    }
    return httpClient;
}

项目：Camel 文件：ScheduledPollEndpoint.java

@Override
protected void configurePollingConsumer(PollingConsumer consumer) throws Exception {
    Map<String, Object> copy = new HashMap<String, Object>(getConsumerProperties());
    Map<String, Object> throwaway = new HashMap<String, Object>();

    // filter out unwanted options which is intended for the scheduled poll consumer
    // as these options are not supported on the polling consumer
    configureScheduledPollConsumerProperties(copy, throwaway);

    // set reference properties first as they use # syntax that fools the regular properties setter
    EndpointHelper.setReferenceProperties(getCamelContext(), consumer, copy);
    EndpointHelper.setProperties(getCamelContext(), consumer, copy);

    if (!isLenientProperties() && copy.size() > 0) {
        throw new ResolveEndpointFailedException(this.getEndpointUri(), "There are " + copy.size()
                + " parameters that couldn't be set on the endpoint polling consumer."
                + " Check the uri if the parameters are spelt correctly and that they are properties of the endpoint."
                + " Unknown consumer parameters=[" + copy + "]");
    }
}

项目：Camel 文件：DefaultComponent.java

/**
 * Strategy for validation of the uri when creating the endpoint.
 *
 * @param uri        the uri
 * @param path       the path - part after the scheme
 * @param parameters the parameters, an empty map if no parameters given
 * @throws ResolveEndpointFailedException should be thrown if the URI validation failed
 */
protected void validateURI(String uri, String path, Map<String, Object> parameters) {
    // check for uri containing double && markers without include by RAW
    if (uri.contains("&&")) {
        Pattern pattern = Pattern.compile("RAW(.*&&.*)");
        Matcher m = pattern.matcher(uri);
        // we should skip the RAW part
        if (!m.find()) {
            throw new ResolveEndpointFailedException(uri, "Invalid uri syntax: Double && marker found. "
                + "Check the uri and remove the duplicate & marker.");
        }
    }

    // if we have a trailing & then that is invalid as well
    if (uri.endsWith("&")) {
        throw new ResolveEndpointFailedException(uri, "Invalid uri syntax: Trailing & marker found. "
            + "Check the uri and remove the trailing & marker.");
    }
}

项目：Camel 文件：DeferServiceStartupListener.java

@Override
public void onCamelContextStarted(CamelContext context, boolean alreadyStarted) throws Exception {
    // new services may be added while starting a service
    // so use a while loop to get the newly added services as well
    while (!services.isEmpty()) {
        Service service = services.iterator().next();
        try {
            ServiceHelper.startService(service);
        } catch (Exception e) {
            if (service instanceof Endpoint) {
                Endpoint endpoint = (Endpoint) service;
                throw new ResolveEndpointFailedException(endpoint.getEndpointUri(), e);
            } else {
                throw e;
            }
        } finally {
            services.remove(service);
        }
    }
}

项目：Camel 文件：DeadLetterChannelBuilderWithInvalidDeadLetterUriTest.java

public void testInvalidOption() throws Exception {
    try {
        context.addRoutes(new RouteBuilder() {
            @Override
            public void configure() throws Exception {
                errorHandler(deadLetterChannel("direct:error?foo=bar"));

                from("direct:start").to("mock:foo");
            }
        });

        fail("Should have thrown an exception");
    } catch (ResolveEndpointFailedException e) {
        assertTrue(e.getMessage().endsWith("Unknown parameters=[{foo=bar}]"));
    }
}

项目：Camel 文件：RecipientListIgnoreInvalidEndpointsTest.java

public void testRecipientListWithoutIgnoreInvalidEndpointsOption() throws Exception {
    MockEndpoint result = getMockEndpoint("mock:result");
    result.expectedMessageCount(0);

    MockEndpoint endpointA = getMockEndpoint("mock:endpointA");
    endpointA.expectedMessageCount(0);

    try {
        template.requestBody("direct:startB", "Hello World", String.class);
        fail("Expect the exception here.");
    } catch (Exception ex) {
        assertTrue("Get a wrong cause of the exception", ex.getCause() instanceof ResolveEndpointFailedException);                         
    }

    assertMockEndpointsSatisfied();
}

项目：Camel 文件：RouteWithMistypedComponentNameTest.java

public void testNoSuchEndpoint() throws Exception {
    CamelContext context = new DefaultCamelContext();
    try {
        context.addRoutes(new RouteBuilder() {
            @Override
            public void configure() throws Exception {
                from("direct:hello").to("mock:result");

                // unknown component
                endpoint("mistyped:hello");
            }
        });
        fail("Should have thrown a ResolveEndpointFailedException");
    } catch (ResolveEndpointFailedException e) {
        // expected
    }
}

项目：Camel 文件：RouteWithMistypedComponentNameTest.java

public void testNoSuchEndpointType() throws Exception {
    CamelContext context = new DefaultCamelContext();
    try {
        context.addRoutes(new RouteBuilder() {
            @Override
            public void configure() throws Exception {
                from("direct:hello").to("mock:result");

                // unknown component
                endpoint("mistyped:hello", Endpoint.class);
            }
        });
        fail("Should have thrown a ResolveEndpointFailedException");
    } catch (ResolveEndpointFailedException e) {
        // expected
    }
}

项目：Camel 文件：CamelPostProcessorHelperTest.java

public void testEndpointInjectProducerTemplateFieldUrlUnknown() throws Exception {
    CamelPostProcessorHelper helper = new CamelPostProcessorHelper(context);

    MyEndpointInjectProducerTemplateUrlUnknown bean = new MyEndpointInjectProducerTemplateUrlUnknown();
    Field field = bean.getClass().getField("producer");

    EndpointInject endpointInject = field.getAnnotation(EndpointInject.class);
    Class<?> type = field.getType();
    String propertyName = "producer";

    try {
        helper.getInjectionValue(type, endpointInject.uri(), endpointInject.ref(), endpointInject.property(), propertyName, bean, "foo");
        fail("Should throw exception");
    } catch (ResolveEndpointFailedException e) {
        assertEquals("Failed to resolve endpoint: xxx://foo due to: No component found with scheme: xxx", e.getMessage());
    }
}

项目：Camel 文件：DefaultCamelContextTest.java

public void testHasEndpoint() throws Exception {
    DefaultCamelContext ctx = new DefaultCamelContext();
    ctx.disableJMX();
    ctx.getEndpoint("mock://foo");

    assertNotNull(ctx.hasEndpoint("mock://foo"));
    assertNull(ctx.hasEndpoint("mock://bar"));

    Map<String, Endpoint> map = ctx.getEndpointMap();
    assertEquals(1, map.size());

    try {
        ctx.hasEndpoint(null);
        fail("Should have thrown exception");
    } catch (ResolveEndpointFailedException e) {
        // expected
    }
}

项目：Camel 文件：LogCustomFormatterTest.java

@Test
public void testCustomFormatterInRegistryUnknownOption() throws Exception {
    context.stop();

    exchangeFormatter = new TestExchangeFormatter();
    JndiRegistry registry = getRegistryAsJndi();
    registry.bind("logFormatter", exchangeFormatter);
    assertEquals("", exchangeFormatter.getPrefix());

    context.start();

    // unknown parameter
    try {
        String endpointUri2 = "log:" + LogCustomFormatterTest.class.getCanonicalName() + "?prefix=foo&bar=no";
        template.requestBody(endpointUri2, "Hello World");
        fail("Should have thrown exception");
    } catch (Exception e) {
        ResolveEndpointFailedException cause = assertIsInstanceOf(ResolveEndpointFailedException.class, e.getCause());
        assertTrue(cause.getMessage().endsWith("Unknown parameters=[{bar=no}]"));
    }
}

项目：Camel 文件：PropertiesComponentDefaultTest.java

public void testPropertiesComponentDefaultNoFileFound() throws Exception {
    context.addRoutes(new RouteBuilder() {
        @Override
        public void configure() throws Exception {
            from("direct:start").to("properties:bar.end?locations=org/apache/camel/component/properties/unknown.properties");
        }
    });
    try {
        context.start();
        fail("Should throw exception");
    } catch (FailedToCreateRouteException e) {
        ResolveEndpointFailedException cause = assertIsInstanceOf(ResolveEndpointFailedException.class, e.getCause());
        FileNotFoundException fnfe = assertIsInstanceOf(FileNotFoundException.class, cause.getCause());
        assertEquals("Properties file org/apache/camel/component/properties/unknown.properties not found in classpath", fnfe.getMessage());
    }
}