Package org.apache.camel

Examples of org.apache.camel.Predicate

296
297
298
299
300
301
302
303
    protected Object assertExpression(Expression expression, String xml, String expected) {
        return assertExpression(expression, createExchange(xml), expected);
    }

    protected void assertPredicate(String xpath, String xml, boolean expected) {
        Predicate predicate = XPathBuilder.xpath(xpath);
        assertPredicate(predicate, createExchange(xml), expected);
    }
View Full Code Here
65
66
67
68
69
70
71
72
73
        exchange.getIn().setBody("Hello");
        exchange.getIn().setHeader("high", true);
        exchange.getIn().setHeader("foo", 123);

        SimplePredicateParser parser = new SimplePredicateParser("${header.high} == false or ${header.foo} == 123");
        Predicate pre = parser.parsePredicate();

        assertTrue("Should match", pre.matches(exchange));
    }
View Full Code Here
427
428
429
430
431
432
433
434
435
436
437
    private List<Predicate> createPredicates() {
        List<Predicate> answer = new ArrayList<Predicate>();
        for (SimpleNode node : nodes) {
            Expression exp = node.createExpression(expression);
            if (exp != null) {
                Predicate predicate = ExpressionToPredicateAdapter.toPredicate(exp);
                answer.add(predicate);
            }
        }
        return answer;
    }
View Full Code Here
128
129
130
131
132
133
134
135
136
137
138
        ObjectHelper.notNull(expression, "expression");

        // trim the expression first
        expression = expression.trim();
        // support old simple language syntax
        @SuppressWarnings("deprecation")
        Predicate answer = SimpleBackwardsCompatibleParser.parsePredicate(expression, allowEscape);
        if (answer == null) {
            // use the new parser
            SimplePredicateParser parser = new SimplePredicateParser(expression, allowEscape);
            answer = parser.parsePredicate();
View Full Code Here
27
28
29
30
31
32
33
34
35
36
37
38
    public void testSimpleRegexp() throws Exception {
        exchange.getIn().setBody("12.34.5678");

        SimplePredicateParser parser = new SimplePredicateParser("${body} regex '^\\d{2}\\.\\d{2}\\.\\d{4}$'");
        Predicate pre = parser.parsePredicate();

        assertTrue(pre.matches(exchange));
       
        exchange.getIn().setBody("12.2a.22ab");
        assertFalse(pre.matches(exchange));
    }
View Full Code Here
58
59
60
61
62
63
64
65
66
67
68
        mock.expectedPropertyReceived(Exchange.AGGREGATED_COMPLETED_BY, "predicate");

        Processor done = new SendProcessor(context.getEndpoint("mock:result"));
        Expression corr = header("id");
        AggregationStrategy as = new BodyInAggregatingStrategy();
        Predicate complete = body().contains("END");

        AggregateProcessor ap = new AggregateProcessor(context, done, corr, as, executorService);
        ap.setCompletionPredicate(complete);
        ap.setEagerCheckCompletion(false);
        ap.start();
View Full Code Here
99
100
101
102
103
104
105
106
107
108
109
        mock.expectedPropertyReceived(Exchange.AGGREGATED_COMPLETED_BY, "predicate");

        Processor done = new SendProcessor(context.getEndpoint("mock:result"));
        Expression corr = header("id");
        AggregationStrategy as = new BodyInAggregatingStrategy();
        Predicate complete = body().isEqualTo("END");

        AggregateProcessor ap = new AggregateProcessor(context, done, corr, as, executorService);
        ap.setCompletionPredicate(complete);
        ap.setEagerCheckCompletion(true);
        ap.start();
View Full Code Here
285
286
287
288
289
290
291
292
293
294
295
        mock.expectedBodiesReceived("A+C+END");

        Processor done = new SendProcessor(context.getEndpoint("mock:result"));
        Expression corr = header("id");
        AggregationStrategy as = new BodyInAggregatingStrategy();
        Predicate complete = body().contains("END");

        AggregateProcessor ap = new AggregateProcessor(context, done, corr, as, executorService);
        ap.setCompletionPredicate(complete);
        ap.setIgnoreInvalidCorrelationKeys(true);
View Full Code Here
325
326
327
328
329
330
331
332
333
334
335
        mock.expectedBodiesReceived("A+C+END");

        Processor done = new SendProcessor(context.getEndpoint("mock:result"));
        Expression corr = header("id");
        AggregationStrategy as = new BodyInAggregatingStrategy();
        Predicate complete = body().contains("END");

        AggregateProcessor ap = new AggregateProcessor(context, done, corr, as, executorService);
        ap.setCompletionPredicate(complete);

        ap.start();
View Full Code Here
372
373
374
375
376
377
378
379
380
381
382
        mock.expectedBodiesReceived("A+B+END");

        Processor done = new SendProcessor(context.getEndpoint("mock:result"));
        Expression corr = header("id");
        AggregationStrategy as = new BodyInAggregatingStrategy();
        Predicate complete = body().contains("END");

        AggregateProcessor ap = new AggregateProcessor(context, done, corr, as, executorService);
        ap.setCompletionPredicate(complete);
        ap.setCloseCorrelationKeyOnCompletion(1000);
View Full Code Here
TOP

Related Classes of org.apache.camel.Predicate

  • akka.camel.CustomRouteTest
  • org.apache.camel.builder.DefaultErrorHandlerBuilder
  • org.apache.camel.builder.ExpressionBuilderTest
  • org.apache.camel.builder.PredicateBuilder
  • org.apache.camel.builder.PredicateBuilderConcurrentTest
  • org.apache.camel.builder.PredicateBuilderTest
  • org.apache.camel.builder.ValueBuilder
  • org.apache.camel.builder.xml.XPathTest
  • org.apache.camel.component.aws.swf.CamelSWFActivityConsumerTest
  • org.apache.camel.component.aws.swf.CamelSWFWorkflowConsumerTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.