Apache骆驼：使用（）中使用复合条件

Question

我正在使用Apache骆驼DSL路由，并且想检查身体是否不是null，并且主体不包含像身份验证失败的子字符串。在Java中类似：

              if(body != null && !body.contains("authenticate failed")) {
                  //Do something.
                  
              }

Apache Camel DSL：

    .choice()
        .when(body().contains("authenticate failed"))
             .log("after choice body().contains('authenticate failed') body: ${body}")
        .when(body().isNotNull()) //Here I want to add the addiontional condition to this when `body not contains authenticate failed`. 

如何编写这样的条件？在过程方法中鉴定对象并写下我的案例？

Answer 1

您可以使用peedicateBuilder创建漂亮的复合谓词。这是如何做简单的身体的示例，不是用谓词构建器进行空白或空检查。

package com.example;

import org.apache.camel.Predicate;
import org.apache.camel.RoutesBuilder;
import org.apache.camel.builder.PredicateBuilder;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.test.junit4.CamelTestSupport;
import org.junit.Test;

public class ExampleTests extends CamelTestSupport {
    

    @Test
    public void testValidBody() throws Exception {

        MockEndpoint resultMockEndpoint = getMockEndpoint("mock:notNull");
        resultMockEndpoint.expectedMessageCount(1);

        template.sendBody("direct:predicateExample", "Hello world!");

        resultMockEndpoint.assertIsSatisfied();
    }

    @Test
    public void testEmptyBody() throws Exception {


        MockEndpoint resultMockEndpoint = getMockEndpoint("mock:nullOrEmpty");
        resultMockEndpoint.expectedMessageCount(1);

        template.sendBody("direct:predicateExample", null);

        resultMockEndpoint.assertIsSatisfied();
    }

    @Test
    public void testNullBody() throws Exception {

        MockEndpoint resultMockEndpoint = getMockEndpoint("mock:nullOrEmpty");
        resultMockEndpoint.expectedMessageCount(1);

        template.sendBody("direct:predicateExample", null);

        resultMockEndpoint.assertIsSatisfied();
    }

    @Override
    protected RoutesBuilder createRouteBuilder() throws Exception {
        return new RouteBuilder() {

            @Override
            public void configure() throws Exception {
             
                Predicate bodyNotNullOrEmpty = PredicateBuilder.and(
                    body().isNotNull(), 
                    body().isNotEqualTo("")
                );

                from("direct:predicateExample")
                    .routeId("predicateExample")
                    .choice().when(bodyNotNullOrEmpty)
                        .log("Received body: ${body}")
                        .to("mock:notNull")
                    .otherwise()
                        .log("Body was null or empty!")
                        .to("mock:nullOrEmpty")
                    .end()
                    .log("done");
            }
        };
    }
}

没有，或者可以将谓词作为参数甚至其他复合谓词列表，这使人们可以做出一些相当复杂的复合谓词。但是，当使用peedicateBuilder开始变得过于冗长时，只需使用处理器或Bean就可以抽象一些复杂性。