Re: Camel RabbitMQ component - Increasing File Descriptors

2013-11-07 Thread Willem jiang
I just checked the code, for the dynamicRouter the endpoint is cached, but the producer is not cached. Please feel free to create a JIRA about it. BTW, I want to know the difference between the RabbitMQ connection and channel to decide if we need to create channel per producer. -- Willem Jian

Re: Dataformat Conversion

2013-11-07 Thread Willem jiang
You can use camel to do that. So what’s your problem? -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/) (English) http://jnn.iteye.com (http://jnn.javaeye.com/) (Chinese) Twitter: willemjiang Weibo: 姜宁

Re: Dataformat Conversion

2013-11-07 Thread Charles Moulliard
To handle FIX Dataformat, you can use camel-bindy and camel-quickfix to communicate with the FIX servers On Thu, Nov 7, 2013 at 8:27 AM, Manoranjitham G < manoranjitha...@polarisft.com> wrote: > Hi, > > I need to convert the consumed message(from http component ) which is in > xml > format to FI

Re: Dataformat Conversion

2013-11-07 Thread Manoranjitham G
Hi, I have just started using camel, I am not familiar with conversions using this. Can you please share me some sample code for conversion. I have tried using dataformats provided with camel,but still I could not convert. Kindly help me. Regards, Manoranjitham G From: "Willem.Jiang [via Ca

Issue after config activemq component transaction

2013-11-07 Thread CamelTyro
Before adding the trasaction configuraiton to activemq component, as below I can send msg to activemq which config by --- After adding the trasaction configuraiton to a

Re: Dataformat Conversion

2013-11-07 Thread Manoranjitham G
Hi, I found that (using Bindydataformat), but I don't know how to use that in the code. Can you please share me some sample code. Thank you, Regards, Manoranjitham G 9698585090 From: "Charles Moulliard-2 [via Camel]" To: Manoranjitham G Date: 11/07/2013 01:56 PM Subject:Re:

Jetty proxy Rest service fails for file uploading

2013-11-07 Thread berdoni
I have deployed on SMX the following Camel route that proxies all ReST request to the real ReST service provider (Tomcat). All ReST calls to SMX routed successfully however a saveDocument service that uploads PDF files fail. public void configure() throws Exception { from("jetty:http://{{smx.host}

OnCompletion issue in Camel-ActiveMQ

2013-11-07 Thread jay
Hi Guys, I have a requirement to call some bean/pojo or processor to clean some stuff once all the messages are processed from the queue (_from). But my on completion is getting invoked for every single message. Could someone let me know your views on what is wrong i am doing here. below is m

Re: Jetty proxy Rest service fails for file uploading

2013-11-07 Thread Willem jiang
camel-jetty support the multipart form post by default, it could cause some trouble if you just want to proxy the request of multipart form post. You can disable this feature by setting enableMultipartFilter option to be false like this. from("jetty:http://{{smx.host}}:{{smx.rest-proxy-port}}/?m

Re: Performance impact of using streamCache="true" in a route

2013-11-07 Thread Claus Ibsen
Hi Not sure if you can say as there is much of an overhead, as you need to access the data 2 times. And the incoming message is streamed so you can only access it once. So to support the use-case you would have to convert the data into a format you can re-read it. The overhead comes if you spool

onException convertions to soapFault

2013-11-07 Thread Delanghe Stefaan
Hey, First i am new to Camel. Hope not for long. :) A question regarding the exception arise for my current project. When I catch a particular exception onException(SocketTimeOutException.class) How can I convert this exception to a soapfault? Kind regards, Stefaan

Re: Performance impact of using streamCache="true" in a route

2013-11-07 Thread Edwin
Apologies, I should have been more specific on the concerns I have around performance. My route won't be writing any data to disk. I'm more concerned about the impact on the memory footprint of the route while stream cache is enabled. -- View this message in context: http://camel.465427.n5.nab

Re: Jetty proxy Rest service fails for file uploading

2013-11-07 Thread berdoni
tnx Williem. I get the same error with enableMultipartFilter=false setting: [Body is instance of org.apache.camel.StreamCache]]. Caused by: [java.lang.IndexOutOfBoundsException - null] I get a similar error when I disable stream cache. from("../../?matchOnUriPrefix=true&enableMultipartFilter=fals

Re: Jetty proxy Rest service fails for file uploading

2013-11-07 Thread Willem jiang
It’s strange. Can you change the route to use camel-http or camel-http4 component to proxy the request? In this way we can tell if it is Jetty Client issue. from("jetty:http://{{smx.host}}:{{smx.rest-proxy-port}}/?matchOnUriPrefix=true";) .to("http://{{real-server-address}}:{{real-ws-port}}/?brid

Re: onException convertions to soapFault

2013-11-07 Thread Willem jiang
You can use try()… catch() to build a SOAP fault like this .doTry() .process(new Processor() { @Override public void process(Exchange exchange) throws Exception { throw new IllegalStateException(); } }) .doCatch(IllegalStateException.class).process(new Processor() { @Override public void process(Ex

Propose add annotation @BeanInject

2013-11-07 Thread alexey-s
It's no secret that the OSGI Blueprint implements a proxy object for the service. In the old specification OSGI used references to objects. Very often forget to let go of the service object obtained from the ServiseReference. For this reason, it is desirable to use the links provided in the bluepri

Re: Jetty proxy Rest service fails for file uploading

2013-11-07 Thread berdoni
Simple Rest services are proxied successfully as with jetty.The saveDocument Rest service fails again for a pdf file. It works OK for small txt files. All at all same behavior but different error message. 2013-11-07 14:26:39,482 | ERROR | p1609546665-2068 | DefaultErrorHandler | 95 -

write servlet response body in subsequent route

2013-11-07 Thread Christian Schaefer
Hi there, I built a route with a servlet-Consumer-Endpoint. from(servlet)to(direct:a) Now I need to write a servlet response in a second route. from(direct:a).process(...).exchange.getOut().setBody("abc") However the caller does't receive the response body after calling the servlet route. (

A question about Content Based Filter

2013-11-07 Thread bonnahu
Hi guys, Currently, I have an incoming message which is type of ClassA. The ClassA has two fields, one field is a byte array, which can be convert to a xml object. I need to do the filtering based on the the value of a tag in the xml. My original thought is to covert the byte array to Document, the

Fwd: [Camel + Websphere MQ ] How to send MQRFH2 properties and ReplyToQ

2013-11-07 Thread Rachit Gandhi
Hi All, I am trying to set MQRFH2 properties (usr proeprties ) using Camel. But When the message arrives on the queue the properties are not set. In the code below I am trying to set a string property and its value (i.e. foo = bar ), but the property is not set when massage arrives on the Queue.

Re: [Camel + Websphere MQ ] How to send MQRFH2 properties and ReplyToQ

2013-11-07 Thread David Karlsen
Hi. Try using this custom implementation of a Spring DestinationResolver which I attached this JIRA: https://jira.springsource.org/browse/SPR-3614 - works for me. Certain MQMD fields are mapped into a JMS set of properties, see: http://publib.boulder.ibm.com/infocenter/wmqv6/v6r0/index.jsp?topic=

Re: A question about Content Based Filter

2013-11-07 Thread Christian Posta
sounds fine... you can then use xpath expression to filter based on the content... On Thu, Nov 7, 2013 at 11:28 AM, bonnahu wrote: > Hi guys, > Currently, I have an incoming message which is type of ClassA. The ClassA > has two fields, one field is a byte array, which can be convert to a xml > ob

Factoring out exception Handling fragments.

2013-11-07 Thread kraythe .
Greetings, I have the following exception handling code on every route that I make. Since it is cut and paste I would love to factor it out into some kind of route fragment that I could use in each route that is using it. Any suggestions on how I could go about this? Direct wont work and the error

Re: [Camel + Websphere MQ ] How to send MQRFH2 properties and ReplyToQ

2013-11-07 Thread nanotech
Hi David, Thanks for the reply. I am not using Spring user. Can you give me a pointer as to how to use in a non-spring setting (i.e. using Java DSL ) -- View this message in context: http://camel.465427.n5.nabble.com/Fwd-Camel-Websphere-MQ-How-to-send-MQRFH2-properties-and-ReplyToQ-tp5742791p57

Re: [Camel + Websphere MQ ] How to send MQRFH2 properties and ReplyToQ

2013-11-07 Thread David Karlsen
camel-jms is based on spring-jms, so the same concept applies. Search for "destinationResolver" on this page: http://camel.apache.org/jms.html http://docs.spring.io/spring/docs/3.2.5.RELEASE/spring-framework-reference/html/jms.html (23.2.3) 2013/11/7 nanotech > Hi David, > Thanks for the reply

Re: onException convertions to soapFault

2013-11-07 Thread alapaka
you can use setFaultBody: ${body} here is a simple velocity script to create the fault document: http://schemas.xmlsoap.org/soap/envelope/";> $exchange.EXCEPTION_CAUGHT $exchange.getExchangeId() -- View this message in context: http://camel.465427.n5.nabble.com/onExceptio

Re: A question about Content Based Filter

2013-11-07 Thread bonnahu
Hi Christian, Thanks for your response. I was planning to use xpath expression, but the body is not xml based content. How to do it? thanks! -- View this message in context: http://camel.465427.n5.nabble.com/A-question-about-Content-Based-Filter-tp5742789p5742799.html Sent from the Camel - User

Re: A question about Content Based Filter

2013-11-07 Thread bonnahu
Are u talking about creating an xpath object using XPathFactory? Will it be more efficient than DOM? -- View this message in context: http://camel.465427.n5.nabble.com/A-question-about-Content-Based-Filter-tp5742789p5742800.html Sent from the Camel - Users mailing list archive at Nabble.com.

Re: Camel and Quartz not playing nice...

2013-11-07 Thread jtoepfer
I am willing to share any more configuration details, if that help fix this issue. Thanks in advance. - Josh Toepfer -- View this message in context: http://camel.465427.n5.nabble.com/Camel-and-Quartz-not-playing-nice-tp5742726p5742790.html Sent from the Camel - Users mailing list archive

poll change files in directory and get file

2013-11-07 Thread sdelanghe
hey i am facing an issue. An endpoint is constructed to poll for modified files in a directory. Endpoint: from("file:" + mainFolderLocation+OUTDATA_OK_FOLDER+"?preMove=./inprogress&move=../done&moveFailed=../error&delay=3&maxMessagesPerPoll=25"+maxMessages) After this i which to get the file

Re: onException convertions to soapFault

2013-11-07 Thread sdelanghe
Thanks for the suggestion. Is it possible to do this directly in the route (onException) , based on thrown exception? Can i avoid using the processor? thnx Stefaan -- View this message in context: http://camel.465427.n5.nabble.com/onException-convertions-to-soapFault-tp5742775p5742788.html Sen

Re: Skip CXF web service interceptors

2013-11-07 Thread kishor
I got the solution at. http://fusesource.com/docs/esb/4.4.1/cxf_interceptors/CXFInterceptorChainManipulation.html -- View this message in context: http://camel.465427.n5.nabble.com/Skip-CXF-web-service-interceptors-tp5742701p5742784.html Sent from the Camel - Users mailing list archive at Nabbl

Re: Jetty proxy Rest service fails for file uploading

2013-11-07 Thread Willem jiang
Can you show me the whole stack trance? It could be helpful if you can catch the HTTP Request and Response without using the proxy. -- Willem Jiang Red Hat, Inc. Web: http://www.redhat.com Blog: http://willemjiang.blogspot.com (http://willemjiang.blogspot.com/) (English) http://jnn