Re: conditional route without dequeuing all messages

Hi You can use jms message selectors to filter only wanted messages. You set these on the jms endpoint. On Mon, Apr 28, 2014 at 7:42 PM, Jack wrote: > Hi, > > I¹m looking for a way to divert messages to an alternative queue based on an > expression. > I was hoping to use the choice mechanism for

RE: Out of Memory For huge Json Response

Thanks much Fernando for your support. We were able to resolve this with streamcaching and readLock check. Regards, Venkat Venkatesh Krishnamoorthy | Service Reinvention – Integration Development Lead | • Target - [Description: Description: Description: cid:image001.png@01CE948A.B9662580] TCS

Re: Issues with Exclusive File ReadLock

Hi Read locks over various file systems can be tricky. If you can then get the other party to write a 2nd done file when the file write is complete. Then you only start consuming the file if there is a "done" file as well. Also you can try readLock=change which detects if the file size / date has

Re: ActiveMQ message not dequeued for a single route with multiple queues

See this FAQ http://camel.apache.org/using-getin-or-getout-methods-on-exchange.html Just use getIn() On Sun, Apr 27, 2014 at 7:35 PM, malcolm davis wrote: > I'm not sure if the following is a bug that needs to be reported, and that > I'm missing something obvious. > > For a single route with mul

Issues with Exclusive File ReadLock

Hi Below is my envmt of Camel application deployment OS: Suse Linux 2.6.34.7-0.3 File System nodes: Distributed file system based out of NAS mounted through NFS. They are mounted on 2 Linux nodes though Camel only runs in one of the node. There is a file reader as shown below: from("file:{{fms

Re: Intermittent STUCK threads in Weblogic Server due to camel application

Can you try to setup the camel cxf producer endpoint synchronous option to be true? With help of the this option camel-cxf producer can use the thread in a manageable way. -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com (English) http://jnn.iteye

Re: ActiveMQ message not dequeued for a single route with multiple queues

I'm not certain but I doubt the behaviour of putting in JMS in the middle of a route would be to both consume a message and then immediately pass pack the message straight off the JMS destination. I would expect it to simply pass back the message unchanged and leave the message alone on the dest

Re: ActiveMQ message not dequeued for a single route with multiple queues

The code fails the same way with Tibco-EMS. This looks like a Camel bug. -- View this message in context: http://camel.465427.n5.nabble.com/ActiveMQ-message-not-dequeued-for-a-single-route-with-multiple-queues-tp5750631p5750666.html Sent from the Camel - Users mailing list archive at Nabble.

Re: Intermittent STUCK threads in Weblogic Server due to camel application

Does anyone have any thought on this issue? Thanks in advance.. -- View this message in context: http://camel.465427.n5.nabble.com/Intermittent-STUCK-threads-in-Weblogic-Server-due-to-camel-application-tp5750624p5750662.html Sent from the Camel - Users mailing list archive at Nabble.com.

Mocking Camel Route Elements in JUnits

Hi all ! I've got a question regarding Unit testing Routes in Camel. I'd like to test only the flow in my Routes having processors as Mockito mocks and producers sending to MockEndpoints + additionally be able to mock Processors defined in on* . I'm using Java DSL + Annotation - Style Spring DI

Re: Transactions: Rollback Destination but Not Dead Letter Queue or Source

No one has any idea on this? It would be really great if I could find the formula to get this to work. *Robert Simmons Jr. MSc. - Lead Java Architect @ EA* *Author of: Hardcore Java (2003) and Maintainable Java (2012)* *LinkedIn: **http://www.linkedin.com/pub/robert-simmons/40/852/a39

Re: Using consumer.bridgeErrorHandler won't allow onException() route to execute completely.

Yeah, this works. Thanks Claus ! Don't know how I missed that. -- View this message in context: http://camel.465427.n5.nabble.com/Using-consumer-bridgeErrorHandler-won-t-allow-onException-route-to-execute-completely-tp5750507p5750656.html Sent from the Camel - Users mailing list archive at Nabb

conditional route without dequeuing all messages

Hi, I¹m looking for a way to divert messages to an alternative queue based on an expression. I was hoping to use the choice mechanism for this. Something like: '10' > ${in.body} The problem with this approach is that all the messages that aren¹t matched by the condition will get dropped. D

Re: Need to write correct Spring XML DSL

https://www.google.com/search?q=camel+spring+DSL&oq=camel+spring+DSL&aqs=chrome..69i57j0l5.3157j0j4&sourceid=chrome&es_sm=91&ie=UTF-8 That should get you started. *Robert Simmons Jr. MSc. - Lead Java Architect @ EA* *Author of: Hardcore Java (2003) and Maintainable Java (2012)* *LinkedIn: **http:

Re: Aggregate Error

Your correlation expression is clearly returning a "" when it is expecting a value that can be converted to an integer. The question would be what does the xpath person/firstName/text() resolve to for each of the files. The easiest way to debug things like this is to turn on a tracer in camel and

Re: Intermittent STUCK threads in Weblogic Server due to camel application

I am trying to understand the basics here. It is possible to have a STUCK thread only when the application does not return back the thread to Weblogic Server within the configured time (10 minutes by default). I have configured my Camel application to disconnect from service I am consuming if i

Re: Sending payload from http to jms...Camel.

I guess you're using POST or PUT to send the message to the HTTP endpoint, right? I've used this route successfully within ServiceMix: http://0.0.0.0:8182/async"/> JMSCorrelationID: ${header.JMSCorrelationID} text/plain

Re: org.apache.camel.language.simple.types.SimpleIllegalSyntaxException: Binary operator is does not support token a at location 11

Simple quote was required --> @Test public void testChoiceSimple() throws InterruptedException { producer.sendBody("direct:input", classA); mockMatch.expectedMessageCount(1); Exchange exch = mockMatch.getExchanges().get(0); Object obj = exch.getIn().getBody

Re: org.apache.camel.language.simple.types.SimpleIllegalSyntaxException: Binary operator is does not support token a at location 11

That's the problem, it works now! Thanks a lot -- View this message in context: http://camel.465427.n5.nabble.com/org-apache-camel-language-simple-types-SimpleIllegalSyntaxException-Binary-operator-is-does-not-supp1-tp5750642p5750645.html Sent from the Camel - Users mailing list archive at Nabb