Camel FTP error trying to route to a ftps server.

2015-03-06 Thread dsumner
The routing works when I send it to another folder using the file producer. Now trying to use ftp2 and encountering an issue trying to send to a ftp site using ssl. I see this warning in the camel logging after it successfully connects and tries to upload a file. WARN o.a.c.c.f.remote.Remote

Re: On Route Completion when using the aggregator

2015-03-06 Thread Harald Neiss
I guess you have implemented your own AggregationStrategy so why don’t you check for the property on the new exchange and copy it to the old one which is forwarded? signature.asc Description: Message signed with OpenPGP using GPGMail

Multicast Position and Exchange Properties

2015-03-06 Thread ychawla
Hello All, I am multicasting and need to alter the document before I send it to different endpoints. To do this, I use onPrepareRef="myProcessor". The issue that I am running into is that the copy of the Exchange that I get does not have much info other than a copy of the exchange. It would be h

Re: On Route Completion when using the aggregator

2015-03-06 Thread harald
I guess you have implemented your own AggregationStrategy so why don’t you check for the property on the new exchange and copy it to the old one which is forwarded?

Re: On Route Completion when using the aggregator

2015-03-06 Thread majid
Thanks Harald I was thinking to do exactly the same thing, send a signal to the seda queue of the second route. The only problem I have with this approach is that once I get the signal, I need to wait until the last aggregated items to complete processing in this route, which mean I have to put so

Re: On Route Completion when using the aggregator

2015-03-06 Thread harald
You are right, it’s in the properties not the header - sorry for that one. If the implementation of the AggregationStrategy keeps the properties from the first exchange to be aggregated with the next 999 ones, the aggregated message will not contain the CamelSplitComplete because it is part of t

Re: On Route Completion when using the aggregator

2015-03-06 Thread majid
CamelSplitComplete is in the property of the exchange, not in the header. Yes, I enabled the tracing and also I run my app in debug mode to check the properties and headers of the exchanges of my second route, and CamelSplitComplete is always false. -- View this message in context: http://came

Re: On Route Completion when using the aggregator

2015-03-06 Thread harald
Hi, seda queues are decoupling your components. So your 2nd routes does not know the splitter in your first route. The consequence is that after each exchange on route 2 the OnCompletion is called. But it does not remove header information so the CamelSplitComplete should be part of the last ex

How to can I call remote REST webservice using apache camel cxf ?

2015-03-06 Thread hoboy
Hi guy I am trying to call a remote REST webservice using camel. I am totally new to camel I have googled but still confused. I there an hello world of this ? a simple example code of how to do this ? -- View this message in context: http://camel.465427.n5.nabble.com/How-to-can-I-call-remote

On Route Completion when using the aggregator

2015-03-06 Thread majid
Hi All, I have 2 camel routes 1st one is streaming and parsing an XML file, then aggregate a chunk of 1000 items and send it a seda queue. 2nd route is persisting these items to the database using jdbc batch. I want on the completion of my second route, to run a finalize process only once at the e

Re: Diff between configuring maxConcurrentConsumers in JMSComponent, Route URI or per JMSEndpoint

2015-03-06 Thread yogu13
Apologies ..l i m confused where does your endpoint uri fit into all this ? is it a different project ? if yes can you let us know the configuration / route for the same ? Regards, -Yogesh -- View this message in context: http://camel.465427.n5.nabble.com/Diff-between-configuring-maxConcurrent

Re: Diff between configuring maxConcurrentConsumers in JMSComponent, Route URI or per JMSEndpoint

2015-03-06 Thread Diego Magalhaes
Sure, @Configuration public class AppCommonsActiveMQContext { private static final String BROKER_URL = "nio:// activemq01.bemobi.com.br:61616?keepAlive=true&jms.prefetchPolicy.queuePrefetch=10 "; @Bean public PooledConnectionFactory pooledConnectionFactory() { PooledConnec

Re: Diff between configuring maxConcurrentConsumers in JMSComponent, Route URI or per JMSEndpoint

2015-03-06 Thread yogu13
this looks good ... can you also share the activemq bean configuration ? Regards, -Yogesh -- View this message in context: http://camel.465427.n5.nabble.com/Diff-between-configuring-maxConcurrentConsumers-in-JMSComponent-Route-URI-or-per-JMSEndpoint-tp5763599p5763732.html Sent from the Camel