Re: Issue in FILE consumer URI having startingDirectoryMustExist set to true

2014-11-25 Thread Willem Jiang
It’s strange your uri is options is start with “?”. You can double check with it? BTW, I just added a unit test[1] to file endpoint, it look like   startingDirectoryMustExist option workd rightly. [1]https://git-wip-us.apache.org/repos/asf?p=camel.git;a=commit;h=3697fbc9 -- Willem Jiang Red

Where to do context setup stuff in a guice enabled camel app

2014-11-25 Thread dermoritz
i am using guice in conjunction with CamelModule in my camel application (standalone using Main). In my case i need to do some things on the context before starting it: context.addRoutePolicyFactory(startUpLogic); context.getRegistry(JndiRegistry.class).bind(CepModule.LOOKUP_DATASOURCE, ds); But

Multicast with multiple timeouts

2014-11-25 Thread gquintana
Hello, I am sending a message to multicast parallel processor with a 2s timeout: I thought the timeout would protect against any slow consumer. But I noticed that as soon a single consumer exceeds timeout, some of the following consumer results are not agregated: I expected to have

Passing several POJOs trough multiple routes

2014-11-25 Thread Router
Hi, I converted data from a file into several POJOs which should be available in different routes for further processing. I tried to store them in the message header (implements Serializable) but they are just available within one route. After passing them to the next they are lost. Do I miss

Re: Passing several POJOs trough multiple routes

2014-11-25 Thread Claus Ibsen
Store them as properties on the exchange On Tue, Nov 25, 2014 at 10:58 AM, Router rou...@trash-mail.com wrote: Hi, I converted data from a file into several POJOs which should be available in different routes for further processing. I tried to store them in the message header (implements

AW: Passing several POJOs trough multiple routes

2014-11-25 Thread jhm
Some components don't forward headers. Maybe you are losing header entries on special components. So instead of searching where you are losing the value, storing as properties, like Claus suggests, seems to be easier. Jan -Ursprüngliche Nachricht- Von: Claus Ibsen

Best way for reusing routes

2014-11-25 Thread Bilgin Ibryam
Hi all, I'd like to write couple of route definitions that will be reused in multiple places. If I use the Java DSL it is straight forward, I can reuse the RouteBuilder class in many places, but I want to use the XML DSL and I can see two options: 1. Use routes statements. Looks like it is

Re: Passing several POJOs trough multiple routes

2014-11-25 Thread Router
Cool thanks, this helps! How would I access this the property via Spring XML? Processor: exchange.setProperty(MyProperty, myObject); // assume method myObject.getName(); Camel.xml: log message={{MyProperty.name}}/ This doesn't work. -- View this message in context:

Re: Best way for reusing routes

2014-11-25 Thread Bilgin Ibryam
Further looking into that, the docs say routeContext is isolated and that that it cannot use onException, intercept, dataFormats from the camelcontext but looking into latest Camel code it can use Does the doc out of date or I'm misinterpreting it? On 25 November 2014 at 11:18, Bilgin Ibryam

FTP2 consumer (SFTP), using localWorkDirectory option - local file not deleted

2014-11-25 Thread fidoedidoe
Hi I'm using a FTP2 consumer for SFTP on a linux OS implementation. Due the the size of the source file (gigabytes), I'm using the option localWorkDirectory. According to the camel documentation http://camel.apache.org/ftp2.html the local local file should be deleted on Exchange completion.

Re: FTP Component configuration

2014-11-25 Thread fidoedidoe
I'm no expert, but could the use of propertyPlaceholder http://camel.apache.org/using-propertyplaceholder.html help achieve similar results (define the FTP details once) and use many?? -- View this message in context:

Re: FTP Component configuration

2014-11-25 Thread Atanas Shindov
Hi Claus and fidoedidoe, thanks for your answers. I was more interested in why the component is designed like this from a conceptual point of view, otherwise - yes, using the properties component would allow me to achieve the same effect. Thanks again. Best regards, Atanas -- View this

Re: Best way for reusing routes

2014-11-25 Thread Claus Ibsen
1 and 2 boils down to the same. routeContextRef will load the routes the same was as #1 does. On Tue, Nov 25, 2014 at 12:18 PM, Bilgin Ibryam bibr...@gmail.com wrote: Hi all, I'd like to write couple of route definitions that will be reused in multiple places. If I use the Java DSL it is

Re: FTP Component configuration

2014-11-25 Thread Claus Ibsen
Because not many do like you. And the ftp component parses the uri to grab the host / port etc. The latter can be fixed though, and thus would require code changes in camel-ftp. Other components may work fine. Its more special case for the ftp that it looks for the host/port from the uri. On

Re: FTP2 consumer (SFTP), using localWorkDirectory option - local file not deleted

2014-11-25 Thread Claus Ibsen
Hi Try without multicast and to make the route as simple to see if the file gets deleted. On Tue, Nov 25, 2014 at 1:40 PM, fidoedidoe gavin.fow...@sagepub.co.uk wrote: Hi I'm using a FTP2 consumer for SFTP on a linux OS implementation. Due the the size of the source file (gigabytes), I'm

Re: Passing several POJOs trough multiple routes

2014-11-25 Thread Router
Thank you guys for your help! Here's a simple example that works for me: DataToPOJOProcessor: exchange.setProperty(MyProperty, myObject); // assume method myObject.getName(); Camel.xml: route id=Myroute1 from uri=MyQueue:incomingData/ process ref=DataToPOJOProcessor/ to

Quartz clustering in camel spring DSL - JIRA CAMEL-8076

2014-11-25 Thread selva
Hi Willem, I have tested with camel 2.14.1-SNAPSHOT and the exception is gone but QueryBuilderProcessor is not getting called from quartz end point. Please find below configuration and logging information for both recovery and success scenario. In success scenario QueryBuilderProcessor is

Re: FTP Component configuration

2014-11-25 Thread Atanas Shindov
That's also my understanding. We could have a behavior similar to camel-jms: do the configuration once on the component level - connection factory, JNDI configurations if necessary, etc., and have it reused by each endpoint instance create with the component. -- View this message in context:

Re: FTP2 consumer (SFTP), using localWorkDirectory option - local file not deleted

2014-11-25 Thread fidoedidoe
Hi Claus Many thanks for your reply. After a small series of tests, I'm concluding that my desire to send a single on completion email when the muticast completes is the the direct / indirect cause for the local file delete to fail. The modified XML DSL below reflects my real world scenario

camel-netty: no response received from remote server.

2014-11-25 Thread bwest
Greetings, I have a need to send a request via tcp to a socket server. I'm trying to use the camel-netty component to do this. So I send a request and then I get I get errors the following error thrown out: *org.apache.camel.CamelExecutionException: Exception occurred during execution on the

Re: FTP Component configuration

2014-11-25 Thread Claus Ibsen
Hi Yeah it can be a good idea for the ftp to support also, you are welcome to log a JIRA and work on a patch with test. On Tue, Nov 25, 2014 at 2:57 PM, Atanas Shindov atanas.shin...@gmail.com wrote: That's also my understanding. We could have a behavior similar to camel-jms: do the

Re: Multicast with multiple timeouts

2014-11-25 Thread gquintana
Clean and simple test case: -- View this message in context: http://camel.465427.n5.nabble.com/Multicast-with-multiple-timeouts-tp5759576p5759596.html Sent from the Camel - Users mailing list archive at Nabble.com.

how do I transform a BSON into JSON using Camel message transformation pattern

2014-11-25 Thread gmh
All, I am reading the oplog of Mongodb in my project in order to synch with redis. The BSON data I am capturing has the following format. { ts: Timestamp(1415124334, 1), op: i, ns: test.products, o: { _id: ObjectId(5459156e7950e8c18c094992), item: card, qty: 15 } } The problem I am

Re: CXF component attachment support for POJO not implemented as specified

2014-11-25 Thread Paul McCulloch
Is it worth my while to submit a patch to support inbound anonymous attachments, I guess with some configuration option to enable the feature? Paul On 21 November 2014 at 17:26, Paul McCulloch pkmccull...@gmail.com wrote: I should probably add that I am trying to handle 'anonymous' attachments

Re: rest client - post a json content to and http enpoint

2014-11-25 Thread scottdawson
Ali, We use the http4 Camel component for POSTing JSON to a REST service, for example: Regards, Scott -- View this message in context: http://camel.465427.n5.nabble.com/rest-client-post-a-json-content-to-and-http-enpoint-tp5759600p5759602.html Sent from the Camel - Users mailing list archive

Re: Temporary queues, or, jms uri from camel uri?

2014-11-25 Thread Gary Kennedy
I'll take it that the answer is Not possible. Cheers, Gary On 19 Nov 2014, at 3:42 pm, Gary Kennedy g...@apnic.net wrote: So I want to talk to a system that will send back several reply messages for a given command message. The general idea is to have a specific route that will process

Servlet component matchOnUriPrefix is not working as documented

2014-11-25 Thread Amit
We are using Servlet component and we route two routes as below. When i send request to (route2) myservice/v1/ it process by route1. As per Servlet component document CamelServlet should try to find a target consumer by matching the URI prefix, if no exact match is found. is not valid.

Re: Temporary queues, or, jms uri from camel uri?

2014-11-25 Thread Minh Tran
I don't know if the Camel JMS component knows how to read from a temporary queue as a consumer. I don't see it listed in the documentation. It certainly knows about it as a producer. You could always implement the listener side using Spring's DefaultMessageListenerContainer directly which can

Re: CXF component attachment support for POJO not implemented as specified

2014-11-25 Thread Willem Jiang
If we cannot access the attachment from the the MessageContentList in POJO model, the solution sounds good. -- 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

Re: Quartz clustering in camel spring DSL - JIRA CAMEL-8076

2014-11-25 Thread Willem Jiang
I did some test on my side, I cannot reproduce the error that you meet. From the failure with recovery log that you showed, The next scheduled is null and Camel Job cannot find the QuartzEndpoint. 2014-11-25 12:29:08,599 [ontext_Worker-1] INFO LoggingTriggerHistoryPlugin  - Trigger

Re: Best way for reusing routes

2014-11-25 Thread Bilgin Ibryam
Thanks Claus. And from top of your head, can you tell me how much is 1 and 2 different to defining routes in a camelContex element? My guess is that I have to go with Java DSL to be on the safe side and be sure that the route definitions will function properly and reused in different camel

Re: Where to do context setup stuff in a guice enabled camel app

2014-11-25 Thread Willem Jiang
It’s not a good idea to setup the camel context inside the RouteBuilder, as it could have some side effect on the other RouteBuilder. CamelContext support to inject the registry, but it doesn’t supper to addRoutePolicyFactory. You may need to find other way to add the RoutePolicyFactory, such

Re: Temporary queues, or, jms uri from camel uri?

2014-11-25 Thread Willem Jiang
Camel JMS Consumer doesn’t need to specify the replyTo option from the endpoint, as it just read the JMS property  to find out the Jms destination to send the reply message. -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com (English)

Re: rest client - post a json content to and http enpoint

2014-11-25 Thread Willem Jiang
I’m so glad to see you already find a way to resolve this kind of issue. -- 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 November 26, 2014 at 5:36:42 AM,

How to pass decrypted password from a bean to FTP uri using camel spring DSL

2014-11-25 Thread Rah
Is there any way to pass the password dynamically to the FTP uri in camel Spring DSL. I tried in the following way which didn't work.Can some one please throw some light to resolve this issue. bean id=rdmEncryptionUtil class=com.test.enc.EncBean/ camel:to

rest client - post a json content to and http enpoint

2014-11-25 Thread salemi
Hi All, I am currently using the cxf-rs to send request to a rest endpoint. Unfortunately the cxf-rs don't work in our new container due to some class loading issues I can't resolve. What other library can use to implement a rest client and is there any example for posting a json content to the

Re: Quartz clustering in camel spring DSL - JIRA CAMEL-8076

2014-11-25 Thread selva
Hi Willem, I have defined one quartz2 endpoint route and one sub route in camel-context.xml file . Whenever the quartz scheduler triggers , the quartz end point will call the sub route using direct component. I am printing some text in console using bean processor(QueryBuilderProcessor) which is

Re: how do I transform a BSON into JSON using Camel message transformation pattern

2014-11-25 Thread Claus Ibsen
Hi You can write some java code that does that, or try a regular expression to replace the ts part. You can then call the java code from the Camel route to transform the message. On Tue, Nov 25, 2014 at 8:51 PM, gmh gordon...@gmail.com wrote: All, I am reading the oplog of Mongodb in my

Re: Servlet component matchOnUriPrefix is not working as documented

2014-11-25 Thread Claus Ibsen
What version of Camel do you use? And as a workaround then try flip the order of the 2 routes. On Tue, Nov 25, 2014 at 11:36 PM, Amit amitpatel2...@gmail.com wrote: We are using Servlet component and we route two routes as below. When i send request to (route2) myservice/v1/ it process by

Re: xmljson component failing to do jsonxml conversion

2014-11-25 Thread Claus Ibsen
Hi Converting first to a string should allow the unmarshal to read the data as an input stream. Are you still having trouble with this? Also you can take a look at the unit tests of camel-xmljson to find samples On Fri, Nov 21, 2014 at 11:15 PM, clinton clint.pe...@ionep.com wrote: Using

Re: camel xmljson add @ signs to the json output. how to remove the @ signs

2014-11-25 Thread Claus Ibsen
Hi Did you get in contact with the xmjson team about the issue and if they are willing to add a flag to turn this on/off etc? On Tue, Nov 18, 2014 at 9:18 AM, Claus Ibsen claus.ib...@gmail.com wrote: Hi Ah great to know it was hardcoded. I would suggest to ask them to add an option so you

camel - xml

2014-11-25 Thread smilevasu6
Hi, I am having xml data like results row EMPNO7369/EMPNO ENAMESMITH/ENAME SAL800/SAL DEPTNO10/DEPTNO /row row EMPNO7499/EMPNO ENAMESMITH/ENAME SAL1600/SAL

RE: camel - xml

2014-11-25 Thread Siano, Stephan
/row/EMPNO/text()), String.class is really not a valid XPath. You probably want to terminate the String before the comma... -Original Message- From: smilevasu6 [mailto:srinivas.thu...@gmail.com] Sent: Mittwoch, 26. November 2014 08:21 To: users@camel.apache.org Subject: camel - xml Hi,

Re: Quartz clustering in camel spring DSL - JIRA CAMEL-8076

2014-11-25 Thread Willem Jiang
Did you clean up your database after testing? S.NO.  TRIGGER_GROUP      JOB_NAME  JOB_GROUP  NEXT_FIRE_TIME  PREV_FIRE_TIME   PRIORITY  TRIGGER_STATE TRIGGER_TYPE  1.     RECOVERING_JOBS    quartz    cluster    141690540     -1              5        SIMPLE        WAITING  2.     cluster