java-Apache Camel中的开关盒

2019-10-26 20:04:31 阅读：148 来源： 互联网

Apache Camel(在Java DSL中)是否有类似于Java交换器的构造？

例如：

 from( incomingRoute )
    .choice()
    .when( simple( "${body.getType} == '" + TYPE.A.name() + "'" ) )
                .to( A_Endpoint )
    .when( simple( "${body.getType} == '" + TYPE.B.name() + "'" ) )
                .to( B_Endpoint )
    .when( simple( "${body.getType} == '" + TYPE.C.name() + "'" ) )
                .to( C_Endpoint )
   .otherwise()
                .to( errorEndpoint );

可以翻译成其他更类似于switch的东西吗？我的意思是我不想使用简单的谓词,而只使用body元素类型的值.
还是我的方法完全错误？ (这可能是合理的)

解决方法:

我通常更喜欢在特定情况下使用Java 8 lambda：

public void configure() throws Exception {
  from( incomingRoute )
     .choice()
     .when( bodyTypeIs( TYPE.A ) )
                 .to( A_Endpoint )
     .when( bodyTypeIs(  TYPE.B ) )
                 .to( B_Endpoint )
     .when( bodyTypeIs(  TYPE.C ) )
                 .to( C_Endpoint )
     .otherwise()
                 .to( errorEndpoint );
}

private Predicate bodyTypeIs(TYPE type) {
  return e -> e.getIn().getBody(BodyType.class).getType() == type;
}

另外,将Camel的Predicates与Java 8结合使用可以构建一些很棒的流利的API,例如添加您自己的功能性Predicate类型：

@FunctionalInterface
public interface ComposablePredicate extends Predicate, java.util.function.Predicate<Exchange> {

  @Override
  default boolean matches(Exchange exchange) {
    return test(exchange);
  }

  @Override
  default ComposablePredicate and(java.util.function.Predicate<? super Exchange> other) {
    Objects.requireNonNull(other);
    return (t) -> test(t) && other.test(t);
  }

  @Override
  default ComposablePredicate negate() {
    return (t) -> !test(t);
  }

  @Override
  default ComposablePredicate or(java.util.function.Predicate<? super Exchange> other) {
    Objects.requireNonNull(other);
    return (t) -> test(t) || other.test(t);
  }
}

这使您可以编写如下内容：

public void configure() throws Exception {
  from( incomingRoute )
     .choice()
     .when( bodyTypeIs( TYPE.A ) .or ( bodyTypeIs( TYPE.A1 ) ) )
                 .to( A_Endpoint )
     .when( bodyTypeIs(  TYPE.B ).negate() )
                 .to( NOT_B_Endpoint )
     .when( bodyTypeIs(  TYPE.C ) .and ( bodyNameIs( "name" ) ) )
                 .to( C_Endpoint )
     .otherwise()
                 .to( errorEndpoint );
}

private ComposablePredicate bodyTypeIs(TYPE type) {
  return e -> bodyFrom(e).getType() == type;
}

private BodyType bodyFrom(Exchange e) {
  return e.getIn().getBody(BodyType.class);
}

private ComposablePredicate bodyNameIs(String name) {
  return e -> bodyFrom(e).getName().equals(name);
}

标签：apache-camel,java
来源： https://codeday.me/bug/20191026/1938863.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

java-Apache Camel中的开关盒