Re: Content Based Router : Java DSL is not working
How to get EndPoint File Directory using camel annotation, I am getting "preMove" directory from Headers, not EndPoint Dir. Looks like I need @Exchange annotation but it is not available. ((FileEndpoint)exchange.getFromEndpoint()).getConfiguration().getDirectory(); Please help me on this. -- View this message in context: http://camel.465427.n5.nabble.com/Content-Based-Router-Java-DSL-is-not-working-tp5767440p5767576.html Sent from the Camel - Users mailing list archive at Nabble.com.
Re: Content Based Router : Java DSL is not working
It looks like your Predicate is a static now, which cannot take the message header as parameter. Please take a look at the Bean Language[1], it shows you how to write a right one. [1]http://camel.apache.org/bean-language.html -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com (English) http://jnn.iteye.com (Chinese) Twitter: willemjiang Weibo: 姜宁willem On May 25, 2015 at 3:33:38 PM, Kondalarv (kondala.sou...@gmail.com) wrote: > I have choice with many options, and using java operation for conditions. > The route is going to otherwise() option always and checckFilePattern() > method is not executing. > > > from(FILE_WATCHER_DSL) > .log(LoggingLevel.INFO, FileWatchDSLUtil.getFileLogPattern()) > .choice() > > .when(checckFilePattern(header("CamelFileAbsolutePath").toString())).process(new > > FileConsumerProcesser()).endChoice() > .otherwise().log("File Patten is not Matched. ${file:absolute.path}") > .to("file:/app/work01/FileWatcherAgent/quarantine").process(new > FileConsumerErrorProcesser()).stop().endChoice() > .end() > .log("End Processing Route"); > ; > > > private static Predicate checckFilePattern(String fileName){ > logger.info("checckFilePattern==> File Name : {}", fileName); > boolean flag = false; > if(fileName.endsWith("txt")) flag= true; > Predicate predicate = PredicateBuilder.constant(flag); > logger.info("checckFilePattern==> predicate: {}", predicate); > return predicate; > } > > > > -- > View this message in context: > http://camel.465427.n5.nabble.com/Content-Based-Router-Java-DSL-is-not-working-tp5767440.html > > Sent from the Camel - Users mailing list archive at Nabble.com. >
Re: Content Based Router : Java DSL is not working
Hi > .when(checckFilePattern(header("CamelFileAbsolutePath").toString())). This is wrong. This code is only invoked once to setup the routes. Use a bean as predicate instead of header for dynamic, and just write it as plain java code public static boolean checkPattern(@Header("CamelFileAbsolutePath") path) { ... } And use a bean as the predicate. On Mon, May 25, 2015 at 9:33 AM, Kondalarv wrote: > I have choice with many options, and using java operation for conditions. > The route is going to otherwise() option always and checckFilePattern() > method is not executing. > > > from(FILE_WATCHER_DSL) > .log(LoggingLevel.INFO, FileWatchDSLUtil.getFileLogPattern()) > .choice() > > .when(checckFilePattern(header("CamelFileAbsolutePath").toString())).process(new > FileConsumerProcesser()).endChoice() > .otherwise().log("File Patten is not Matched. > ${file:absolute.path}") > > .to("file:/app/work01/FileWatcherAgent/quarantine").process(new > FileConsumerErrorProcesser()).stop().endChoice() > .end() > .log("End Processing Route"); > ; > > > private static Predicate checckFilePattern(String fileName){ > logger.info("checckFilePattern==> File Name : {}", fileName); > boolean flag = false; > if(fileName.endsWith("txt")) flag= true; > Predicate predicate = PredicateBuilder.constant(flag); > logger.info("checckFilePattern==> predicate: {}", predicate); > return predicate; > } > > > > -- > View this message in context: > http://camel.465427.n5.nabble.com/Content-Based-Router-Java-DSL-is-not-working-tp5767440.html > Sent from the Camel - Users mailing list archive at Nabble.com. -- Claus Ibsen - Red Hat, Inc. Email: cib...@redhat.com Twitter: davsclaus Blog: http://davsclaus.com Author of Camel in Action: http://www.manning.com/ibsen hawtio: http://hawt.io/ fabric8: http://fabric8.io/
Re: Content Based Router : Java DSL is not working
Hi, I would suggest to split the route in smaller route using direct and then check from(FILE_WATCHER_DSL) .log(LoggingLevel.INFO, FileWatchDSLUtil.getFileLogPattern()) .choice() .when(checckFilePattern(header("CamelFileAbsolutePath").toString())) .to(direct:process) .otherwise() .to(direct:processOtherwise) place the logic in respective direct endpoints. -- View this message in context: http://camel.465427.n5.nabble.com/Content-Based-Router-Java-DSL-is-not-working-tp5767440p5767443.html Sent from the Camel - Users mailing list archive at Nabble.com.
Content Based Router : Java DSL is not working
I have choice with many options, and using java operation for conditions. The route is going to otherwise() option always and checckFilePattern() method is not executing. from(FILE_WATCHER_DSL) .log(LoggingLevel.INFO, FileWatchDSLUtil.getFileLogPattern()) .choice() .when(checckFilePattern(header("CamelFileAbsolutePath").toString())).process(new FileConsumerProcesser()).endChoice() .otherwise().log("File Patten is not Matched. ${file:absolute.path}") .to("file:/app/work01/FileWatcherAgent/quarantine").process(new FileConsumerErrorProcesser()).stop().endChoice() .end() .log("End Processing Route"); ; private static Predicate checckFilePattern(String fileName){ logger.info("checckFilePattern==> File Name : {}", fileName); boolean flag = false; if(fileName.endsWith("txt")) flag= true; Predicate predicate = PredicateBuilder.constant(flag); logger.info("checckFilePattern==> predicate: {}", predicate); return predicate; } -- View this message in context: http://camel.465427.n5.nabble.com/Content-Based-Router-Java-DSL-is-not-working-tp5767440.html Sent from the Camel - Users mailing list archive at Nabble.com.