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

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      

RE: camel - xml

"/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

camel - xml

Hi, I am having xml data like 7369 SMITH 800 10 7499 SMITH> 1600 20 7521 SMITH

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

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 wrote: > Hi > > Ah great to know it was hardcoded. I would suggest to ask them to add > an option so you can turn that off. A

Re: xmljson component failing to do json>xml conversion

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 wrote: > Using camel's xmljson, I had no

Re: Servlet component matchOnUriPrefix is not working as documented

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 wrote: > 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

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

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 wrote: > > All, > I am reading the oplog of Mongodb in my project in order to

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

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 d

rest client - post a json content to and http enpoint

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 e

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

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. {{ftp.password}} will be in the encrypted form reading it from the properties file. Thanks in Adva

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

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, scottdaw

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

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) http://jnn.ite

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

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 as

Re: Best way for reusing routes

Thanks Claus. And from top of your head, can you tell me how much is 1 and 2 different to defining routes in a 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 contexts defined i

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

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 [RECOVERING_JO

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

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 Nove

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

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 s

Servlet component matchOnUriPrefix is not working as documented

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. rou

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

I'll take it that the answer is "Not possible". Cheers, Gary On 19 Nov 2014, at 3:42 pm, Gary Kennedy 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 the reply

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

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: CXF component attachment support for POJO not implemented as specified

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 wrote: > I should probably add that I am trying to handle 'anonymous' attachments - > they are not ref

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

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 } }

Re: Multicast with multiple timeouts

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.

Re: FTP Component configuration

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 wrote: > That's also my understanding. We could have a behavior similar to camel-jms: > do the configuration once on the compone

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

It could be because you remove the file name headers, try not doing that. On Tue, Nov 25, 2014 at 4:01 PM, fidoedidoe wrote: > 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 > complet

camel-netty: no response received from remote server.

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: FTP2 consumer (SFTP), using "localWorkDirectory" option - local file not deleted

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 mo

Re: FTP Component configuration

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: ht

Quartz clustering in camel spring DSL - JIRA CAMEL-8076

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 gettin

Re: Passing several POJOs trough multiple routes

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: -- View this message in context: http://came

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

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 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 using the option > "localW

Re: FTP Component configuration

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 T

Re: Best way for reusing routes

1 and 2 boils down to the same. will load the routes the same was as #1 does. On Tue, Nov 25, 2014 at 12:18 PM, Bilgin Ibryam 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 straight forward, I can reus

Re: FTP Component configuration

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 messag

Re: FTP Component configuration

I'm no expert, but could the use of propertyPlaceholder help achieve similar results (define the FTP details once) and use many?? -- View this message in context: http://camel.465427.n5.nabble.com/FTP-Component-configuration-tp5759497p

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

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 the local local file should be deleted on Exchange completion.

Re: Best way for reusing routes

Further looking into that, the docs say " is isolated and that that it cannot use , , 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 wrote: > Hi all, > > I'd like to write

Re: Passing several POJOs trough multiple routes

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: This doesn't work. -- View this message in context: http://camel.465427.n5.nabble.com/Passing-several-POJ

Best way for reusing routes

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 statements. Looks like it is mostly used

AW: Passing several POJOs trough multiple routes

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 [mailto:claus.ib.

Re: Passing several POJOs trough multiple routes

Store them as properties on the exchange On Tue, Nov 25, 2014 at 10:58 AM, Router 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 Serializable) but th

Passing several POJOs trough multiple routes

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 some

Multicast with multiple timeouts

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 "HELL

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

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); Bu

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

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