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

项目：Camel 文件：DefaultEndpoint.java

/**
 * A factory method to lazily create the endpoint configuration if none is specified
 */
protected EndpointConfiguration createEndpointConfiguration(String uri) {
    // using this factory method to be backwards compatible with the old code
    if (getComponent() != null) {
        // prefer to use component endpoint configuration
        try {
            return getComponent().createConfiguration(uri);
        } catch (Exception e) {
            throw ObjectHelper.wrapRuntimeCamelException(e);
        }
    } else if (getCamelContext() != null) {
        // fallback and use a mapped endpoint configuration
        return new MappedEndpointConfiguration(getCamelContext(), uri);
    }
    // not configuration possible
    return null;
}

项目：Camel 文件：ConfigurationHelper.java

public static EndpointConfiguration createConfiguration(String uri, CamelContext context) throws Exception {
    int schemeSeparator = uri.indexOf(':');
    if (schemeSeparator == -1) {
        // not an URIConfiguration
        return null;
    }
    String scheme = uri.substring(0, schemeSeparator);

    Component component = context.getComponent(scheme);
    if (LOG.isTraceEnabled()) {
        LOG.trace("Lookup for Component handling \"{}:\" configuration returned {}",
            new Object[]{scheme, component != null ? component.getClass().getName() : "<null>"});
    }
    if (component != null) {
        EndpointConfiguration config = component.createConfiguration(scheme);
        if (config instanceof DefaultEndpointConfiguration) {
            ((DefaultEndpointConfiguration) config).setURI(uri);
        }
        return config;
    } else {
        // no component to create the configuration
        return null;
    }
}

项目：Camel 文件：ConfigurationHelper.java

public static void populateFromURI(CamelContext camelContext, EndpointConfiguration config, ParameterSetter setter) {
    URI uri = config.getURI();

    setter.set(camelContext, config, EndpointConfiguration.URI_SCHEME, uri.getScheme());
    setter.set(camelContext, config, EndpointConfiguration.URI_SCHEME_SPECIFIC_PART, uri.getSchemeSpecificPart());
    setter.set(camelContext, config, EndpointConfiguration.URI_AUTHORITY, uri.getAuthority());
    setter.set(camelContext, config, EndpointConfiguration.URI_USER_INFO, uri.getUserInfo());
    setter.set(camelContext, config, EndpointConfiguration.URI_HOST, uri.getHost());
    setter.set(camelContext, config, EndpointConfiguration.URI_PORT, Integer.toString(uri.getPort()));
    setter.set(camelContext, config, EndpointConfiguration.URI_PATH, uri.getPath());
    setter.set(camelContext, config, EndpointConfiguration.URI_QUERY, uri.getQuery());
    setter.set(camelContext, config, EndpointConfiguration.URI_FRAGMENT, uri.getFragment());

    // now parse query and set custom parameters
    Map<String, Object> parameters;
    try {
        parameters = URISupport.parseParameters(uri);
        for (Map.Entry<String, Object> pair : parameters.entrySet()) {
            setter.set(camelContext, config, pair.getKey(), pair.getValue());
        }
    } catch (URISyntaxException e) {
        throw new RuntimeCamelException(e);
    }
}

项目：Camel 文件：ConfigurationHelper.java

public static Field findConfigurationField(EndpointConfiguration config, String name) {
    if (config != null && name != null) {
        Class<?> clazz = config.getClass();
        Field[] fields = clazz.getDeclaredFields();

        Field found;
        URIField anno;
        for (final Field field : fields) {
            anno = field.getAnnotation(URIField.class);
            if (anno == null ? field.getName().equals(name) : anno.component().equals(name) 
                || (anno.component().equals(EndpointConfiguration.URI_QUERY) && anno.parameter().equals(name))) { 

                found = field;
                LOG.trace("Found field {}.{} as candidate for parameter {}", new Object[]{clazz.getName(), found.getName(), name});
                return found;
            }
        }
    }            
    return null;
}

项目：Camel 文件：DataSetComponentConfigurationAndDocumentationTest.java

@Test
public void testComponentConfiguration() throws Exception {
    DataSetComponent comp = context.getComponent("dataset", DataSetComponent.class);
    EndpointConfiguration conf = comp.createConfiguration("dataset:foo?minRate=3&produceDelay=33&consumeDelay=333&preloadSize=3333&initialDelay=33333&disableDataSetIndex=true");

    assertEquals("Unexpected endpoint configuration value for minRate", "3", conf.getParameter("minRate"));
    assertEquals("Unexpected endpoint configuration value for produceDelay", "33", conf.getParameter("produceDelay"));
    assertEquals("Unexpected endpoint configuration value for consumeDelay", "333", conf.getParameter("consumeDelay"));
    assertEquals("Unexpected endpoint configuration value for preloadSize", "3333", conf.getParameter("preloadSize"));
    assertEquals("Unexpected endpoint configuration value for initialDelay", "33333", conf.getParameter("initialDelay"));
    assertEquals("Unexpected endpoint configuration value for disableDataSetIndex", "true", conf.getParameter("disableDataSetIndex"));

    ComponentConfiguration compConf = comp.createComponentConfiguration();
    String json = compConf.createParameterJsonSchema();
    assertNotNull(json);

    assertTrue(json.contains("\"name\": { \"kind\": \"path\", \"group\": \"common\", \"required\": \"true\", \"type\""));
    assertTrue(json.contains("\"kind\": \"parameter\", \"group\": \"consumer\", \"label\": \"consumer\", \"type\": \"integer\""));
    assertTrue(json.contains("\"retainFirst\": { \"kind\": \"parameter\", \"group\": \"producer\", \"label\": \"producer\", \"type\": \"integer"));
}

项目：Camel 文件：DataFormatComponentConfigurationAndDocumentationTest.java

@Test
public void testComponentConfiguration() throws Exception {
    DataFormatComponent comp = context.getComponent("dataformat", DataFormatComponent.class);
    EndpointConfiguration conf = comp.createConfiguration("dataformaat:marshal:string?charset=iso-8859-1");

    assertEquals("iso-8859-1", conf.getParameter("charset"));

    ComponentConfiguration compConf = comp.createComponentConfiguration();
    String json = compConf.createParameterJsonSchema();
    assertNotNull(json);

    assertTrue(json.contains("\"name\": { \"kind\": \"path\", \"group\": \"producer\", \"required\": \"true\", \"type\": \"string\", \"javaType\": \"java.lang.String\","
                    + " \"deprecated\": \"false\", \"description\": \"Name of data format\" }"));
    assertTrue(json.contains("\"operation\": { \"kind\": \"path\", \"group\": \"producer\", \"required\": \"true\", \"type\": \"string\""));
    assertTrue(json.contains("\"synchronous\": { \"kind\": \"parameter\", \"group\": \"advanced\", \"label\": \"advanced\", \"type\": \"boolean\""));
}

项目：Camel 文件：FileComponentConfigurationAndDocumentationTest.java

@Test
public void testComponentConfiguration() throws Exception {
    FileComponent comp = context.getComponent("file", FileComponent.class);
    EndpointConfiguration conf = comp.createConfiguration("file:target/foo?delete=true");

    assertEquals("true", conf.getParameter("delete"));

    ComponentConfiguration compConf = comp.createComponentConfiguration();
    String json = compConf.createParameterJsonSchema();
    assertNotNull(json);

    assertTrue(json.contains("\"directoryName\": { \"kind\": \"path\", \"group\": \"common\", \"required\": \"true\""));
    assertTrue(json.contains("\"doneFileName\": { \"kind\": \"parameter\", \"group\": \"producer\", \"label\": \"producer\", \"type\": \"string\""));
    assertTrue(json.contains("\"autoCreate\": { \"kind\": \"parameter\", \"group\": \"advanced\", \"label\": \"advanced\", \"type\": \"boolean\""));
    assertTrue(json.contains("\"readLockMinAge\": { \"kind\": \"parameter\", \"group\": \"lock\", \"label\": \"consumer,lock\""));
}

项目：Camel 文件：UriConfigurationTest.java

@Test
public void testComponentConfiguration() throws Exception {
    CamelContext context = new DefaultCamelContext();

    BeanstalkComponent comp = context.getComponent("beanstalk", BeanstalkComponent.class);
    EndpointConfiguration conf = comp.createConfiguration("beanstalk:tube?command=put");

    assertEquals("put", conf.getParameter("command"));

    ComponentConfiguration compConf = comp.createComponentConfiguration();
    String json = compConf.createParameterJsonSchema();
    assertNotNull(json);

    assertTrue(json.contains("\"command\": { \"kind\": \"parameter\", \"group\": \"common\", \"type\": \"string\""));
    assertTrue(json.contains("\"jobTimeToRun\": { \"kind\": \"parameter\", \"group\": \"common\", \"type\": \"integer\""));
    assertTrue(json.contains("\"awaitJob\": { \"kind\": \"parameter\", \"group\": \"consumer\", \"label\": \"consumer\", \"type\": \"boolean\""));
}

项目：Camel 文件：ConfigurationHelper.java

public static Object getConfigurationParameter(EndpointConfiguration config, Field field) {
    if (field != null) {
        try {
            return IntrospectionSupport.getProperty(config, field.getName());
        } catch (Exception e) {
            throw new RuntimeCamelException("Failed to get property '" + field.getName() + "' on " + config + " due " + e.getMessage(), e);
        }
    }
    return null;
}

项目：Camel 文件：ConfigurationHelper.java

public static <T> void setConfigurationField(CamelContext camelContext, EndpointConfiguration config, String name, T value) {
    Field field = findConfigurationField(config, name);
    if (field == null) {
        return;
    }

    try {
        IntrospectionSupport.setProperty(camelContext.getTypeConverter(), config, name, value);
    } catch (Exception e) {
        throw new RuntimeCamelException("Failed to set property '" + name + "' on " + config + " due " + e.getMessage(), e);
    }
}

项目：Camel 文件：MappedEndpointConfiguration.java

@Override
protected void parseURI() {
    ConfigurationHelper.populateFromURI(getCamelContext(), this, new ConfigurationHelper.ParameterSetter() {
        @Override
        public <T> void set(CamelContext camelContext, EndpointConfiguration config, String name, T value) {
            if (name != null && value != null) {
                params.put(name, value);
            }
        }
    });
}