Re: Camel aggregation logic fails in case of two camel nodes

Hi You need to use a persistent aggregation repository implementation. There is a little detail here http://camel.apache.org/aggregator2 Notice that hawtdb is being @deprecated and consider using camel-leveldb instead. Or any other custom implementation. There is a SQL based implementation as we

Re: how to get the ftp reply when uploading a file

I've added a pull request to solve this problem https://github.com/apache/camel/pull/19 - asbjørn -- View this message in context: http://camel.465427.n5.nabble.com/how-to-get-the-ftp-reply-when-uploading-a-file-tp5730960p5730996.html Sent from the Camel - Users mailing list archive at Nabble.

Camel aggregation logic fails in case of two camel nodes

Hi, I have a use case where I have used splitter and aggregation patterns. The diagram below shows the message flow. I have a message with ten trades: it reaches the splitter -> gets split into ten messages -> each message gets enriched -> after enrichment, the messages are aggregated into sing

Re: Splitting XML into multiple separate bits and send out to webservices

Why do you need to intercept those endpoints? Do you plan to use it in your unit test? -- Willem Jiang Red Hat, Inc. FuseSource is now part of Red Hat Web: http://www.fusesource.com | http://www.redhat.com Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/) (English)

Camel Reciepient List

>From this thread, http://www.mentby.com/Group/apache-camel/recipientlist-aggregationstrategy-and-completiontimeout.html ,i understand dynamic timeout is not possible in receipient List.Something like in aggregate where timeout can be configured via Expression.Is it still case with Camel 2.10.2.It

Re: Splitting XML into multiple separate bits and send out to webservices

I don't think the splitter can do what I want. I want to take a single message, transform that message into X messages (sometimes it might split, other times I'll have to take the original incoming message, transform it based on an element based inside the message). Looking at other forums, some

Re: Splitting XML into multiple separate bits and send out to webservices

Thanks for the reply Clause. I've read the Split part and I understand it. Based on my above example I know what I want to split, I'm just not sure how the XML should look for the Split. Example (psudo): When an incoming message hits this section, it could only satisfy 1 of the splits, other

Re: CronScheduledRoutePolicy example

It is a Quartz cron expression, you can read about it here: http://quartz-scheduler.org/documentation/quartz-1.x/tutorials/crontrigger Normally you wouldn't use * with /, but I guess that works as well. In your configuration it will start every 3 seconds. 2013/4/16 pokkie > Hi, > > I am looki

CronScheduledRoutePolicy example

Hi, I am looking at the CronScheduledRoutePolicy that is published on the Camel Website. It has the following code snippet: CronScheduledRoutePolicy startPolicy = new CronScheduledRoutePolicy(); startPolicy.setRouteStartTime("*/3 * * * * ?"); from("direct:start") .routeId("

Bindy fixed length

Hi, Is there anything similar to Hibernate's components in bindy? It would be nice if we can nest objects to model one line. Thanks. -- View this message in context: http://camel.465427.n5.nabble.com/Bindy-fixed-length-tp5730980.html Sent from the Camel - Users mailing list archive at Nabble.

ftpConsumer still remain in threadpools

Hello, I get file with uri : ftp://directory?include=.*HPR&doneFileName=${file:name.noext}.OK&delete=true Once I get the file, I read another one in a bean : from(url) ... .bean(classEnrich, "enrich") ... In enrich, I read the third file named using (uri is modified to designate the file) : Con

Re: Creating new processor components

Hi ! Claus Ibsen-2 wrote > For the component name, then make sure the > META-INF/services/org/apache/camel/component/helloworld file is > included in the JAR. And that it refers to the component class name. > > For example here is an example from camel-mybatis component: > https://svn.apache.org

Re: How to Use ProducerTemplate for testing secure CXF-WS?

Hi I don't think you set the right payload message as soap body element is empty. BTW, if the request doesn't hit the route, you need to check the log file to see if there anything wrong on the ProducerTemplate side. -- Willem Jiang Red Hat, Inc. FuseSource is now part of Red Hat Web: http

Re: Camel routing issue

*One quick question.* from("activemq:queue:HHH.InboundQueue").multicast().beanRef("recipientsGenerator") @RecipientList() public Set routeTo(Exchange ex) { final Set destinations = new HashSet(); //based on condition we add messages header/content ,We add queue names in destinations varible.

Re: InterceptSendToEndpoint - Http Component

Hi, tried to use this feature for testing - excellently like advised - it still did not skip intercepted endpoint. Camel 2.10.4 What I am doing wrong? The first endpoint changed and worked; In the log I see trying to post message to localhost. And test fell down with exception. I simply want to r

Re: Camel xmpp dynamic router is not connecting to openfire.

I have added comment to JIRA issue -- View this message in context: http://camel.465427.n5.nabble.com/Camel-xmpp-dynamic-router-is-not-connecting-to-openfire-tp5730506p5730964.html Sent from the Camel - Users mailing list archive at Nabble.com.

Using the Servlet component in a Blueprint container

Hello Community, I apologize for the long post upon list entry, but I thought this might be interesting. I was working on a use case that involves running Camel inside an OSGi Container and for configuration I am using Apache Aries 1.0.0. As i have a HTTP Service already running and need to sup

how to get the ftp reply when uploading a file

Using Camel 2.11-SNAPSHOT I need to fetch the "250 OK .." reply line because the ftp server we have to connect to use this line to tell us the server name of the uplaoded file. When looking in the camel-ftp source I only find references to client.storeFile() which returns a boolean. Has anybo

Re: How to Use ProducerTemplate for testing secure CXF-WS?

Hi Willem, thanks for your response. I'm using PAYLOAD-mode in my cxf consumer. I already found the page you referred to and tried to set the headers of the CxfPayload-object like this: Processor soapHeaderProcessor = new Processor() { public void process(Exchange exchange) throws E

Re: Custom URIResolver for XSLT component

Thanks for quick response. I was sure that @Qualifier annotation gives an id to bean. Now I have it working with annotations too -- View this message in context: http://camel.465427.n5.nabble.com/Custom-URIResolver-for-XSLT-component-tp5730913p5730957.html Sent from the Camel - Users mailing li

Block a Queue until all exchanges are received

Hi Guys, Having a route DSL as: from("file:" + classesBaseDir + "/" + fileType + "/step0?preMove=inprogress&moveFailed=.error&move=.done&readLock=true") .routeId(dirRepoPrefix + fileType + "-To-" + queuePrefix + fileType + "_ParsingQ") .threads(50) .split().tokenize("\n", 5).streaming().parallelP

Re: Log in file

Thanks very much Raul ! 2013/4/12 Raul Kripalani > Hi Jean Francois, > > What you need is exactly the SiftAppender, which will log to a different > file depending on some dynamic parameter in the Mapped Diagnostic Context > (MDC). > > Use this appender from log4j: org.apache.log4j.sift.MDCSifti