让camel使用Map构建端点uri

Question

Map<String, String>有没有办法让camel使用包含请求参数 的端点创建uri ？

我经常遇到这样的情况，我通过配置获得不同的参数，并且必须在运行时以编程方式构建 uri（之后是静态的）。
目前我总是必须自己构建 uri，这可以找到，但我想知道是否有更干净的方法。

例如，这就是我使用某些配置构建 smtp enpoint 的 uri 的方法（可能不是最简单的代码，但它工作正常）：

private String buildSmtpUri() {
  StringBuilder sb = new StringBuilder();
  if (configuration.isEnableSslSecurity()) {
    sb.append("smtps://");
  } else {
    sb.append("smtp://");
  }
  Assert.hasText(configuration.getSmtpUrl(), "No smtp url was given");
  sb.append(configuration.getSmtpUrl());
  if (configuration.getPort() != null) {
    sb.append(":");
    sb.append(configuration.getPort());
  }
  Map<String, String> parameters = new HashMap<>();
  if (StringUtils.isNotEmpty(configuration.getUsername())) {
    parameters.put("username", configuration.getUsername());
  }
  if (StringUtils.isNotEmpty(configuration.getPassword())) {
    parameters.put("password", configuration.getPassword());
  }
  if (configuration.isBodyIsHtml()) {
    parameters.put("contentType", "text/html");
  }

  AtomicBoolean first = new AtomicBoolean(true);
  parameters.forEach((key, value) -> {
    if (first.get()) {
      first.set(false);
      sb.append("?");
    } else {
      sb.append("&");
    }
    sb.append(key)
        .append("=")
        .append(value);
  });

  return sb.toString();
}

如果这不能使用一些骆驼接口来简化，也许它在未来可能是一个很酷的功能？

问候克里斯

Answer 1

您可以使用方法动态Component#createEndpoint构建实例。Endpoint

public class MyRouteBuilder extends RouteBuilder {
    @Override
    public void configure() throws Exception{
        from(dynamicEndpoint("seda", "mySeda", Collections.singletonMap("size", "123")))
                .to("log:Hello from SEDA");
    }

    private Endpoint dynamicEndpoint(String component, String name, Map<String, Object> params) throws Exception {
        return getContext().getComponent(component).createEndpoint(name, params);
    }
}

在Camel 2.x中，也有解决方案，虽然不是那么优雅

private Endpoint dynamicEndpoint(String component, String name, Map<String, Object> params) throws Exception {
    String uri = String.format("%s://%s?%s", component, name, org.apache.camel.util.URISupport.createQueryString(params));
    return getContext().getEndpoint(uri);
}