Re: Camel-JMS JMS Selector getting overridden by new requests

2015-12-08 Thread ravi.4indra
are the endpoints shared between multiple threads even if the bean is of protoype scope? -- View this message in context: http://camel.465427.n5.nabble.com/Camel-JMS-JMS-Selector-getting-overridden-by-new-requests-tp5774806p5774838.html Sent from the Camel - Users mailing list archive at

Camel-JMS JMS Selector getting overridden by new requests

2015-12-07 Thread ravi.4indra
Hi We are having a issue where our Selector mesageid is being overidden by the messageid from new requests. Its like endpoints are being cached and same endpoints are being reused. beanprocessor code @EndpointInject(uri = "bxJmscomponent:queueName") JmsEndpoint endpointJMS;

camel-JMS Component Responses from multiple queues

2015-10-20 Thread ravi.4indra
Hi, I am looking for some suggestions on scenario where response to a request sent to queue can come in any one of the three queues. is there a way in camel to check for responses in multiple queues. Thanks ravi -- View this message in context:

Warning Messages in Logs when camel application running on multiple nodes

2015-05-13 Thread ravi.4indra
Hi, I have a route using camel file2 to move a file. its working fine with a single node but with camel running on three different nodes i am seeing below error on 2 nodes and successfully processing in the third server. is there a configuration or option on camel to prevent this

RE: Input directory with multiple file consumers

2015-01-29 Thread ravi.4indra
I ran into a similar issue and exploring options for this. does reducing the delay between polls to very low value (10) increases with file consumption on both the nodes? -- View this message in context:

Camel is running only one route at a point of time

2015-01-28 Thread ravi.4indra
I have camel context with routes like this from(file:dir1) //some processing .to(file:dir2) from(file:dir2) //some processing .to(file:dir3) from(file:dir3) //some processing .to(file:dir4) from(file:dir6) //some processing .to(file:dir7) we have a huge no of files going through the

Re: camel-cxf component is encoding(base64) by default

2014-06-15 Thread ravi.4indra
loos like it's the cxf behaviour to decode the base64. but I could not find this in cxf docs. -- View this message in context: http://camel.465427.n5.nabble.com/camel-cxf-component-is-encoding-base64-by-default-tp5750705p5752303.html Sent from the Camel - Users mailing list archive at

camel-cxf component is encoding(base64) by default

2014-04-29 Thread ravi.4indra
Hi , I am consuming the web service using the camel-cxf component. Below is how the element defined in wsdl. xs:element name=elementA ns1:expectedContentTypes=application/octet-stream type=xs:base64Binary xmlns:ns1=http://www.w3.org/2005/05/xmlmime/ javaCode: element A is encoded base64 String

Re: Camel-cxf rs client bean

2014-04-01 Thread ravi.4indra
Hi, This is how my route looks like from(direct:start).routeId(start) .bean(Processor1.class, prepareRequestMessage) .to(cxfrs:bean:rsClient?synchronous=true) .bean(Processor1.class, processResponseMessage) prepareRequestMessage

Re: Camel-cxf rs client bean

2014-04-01 Thread ravi.4indra
Hi, This is how my route looks like from(direct:start).routeId(start) .bean(Processor1.class, prepareRequestMessage) .to(cxfrs:bean:rsClient?synchronous=true) .bean(Processor1.class, processResponseMessage)

Camel-cxf rs client bean

2014-03-31 Thread ravi.4indra
Hi, I am having trouble defining a cxf rs client bean. can anyone point me the example of defining a cxf client bean using the http client. Any Help is appreciated Thanks Ravi -- View this message in context: http://camel.465427.n5.nabble.com/Camel-cxf-rs-client-bean-tp5749587.html Sent

Camel-JmsComponent ThreadContext issues

2013-09-27 Thread ravi.4indra
Hi, we set the ThreadContext value for every request coming in and we use that value in logging. when the message is picked up from the queue (which is done by QueueReplyManager which runs in a different thread) the thread context value in that thread(QueueReplyManager thread) is remaining same

Issue with the request timeout in camel-jms component

2013-08-12 Thread ravi.4indra
Hi , It would be hlepful if anyone can provide update on the issue. issue as described in jira *When performing an InOut JMS exchange with a certain requestTimeout, if the reply message is received in time, but the following formula stands true: {{T0 + T1 = T!}}, where: T0 = JMS response

Re: CAMEL -JMS Request TimeOut

2012-11-02 Thread ravi.4indra
Thanks Willem!! I am seeing this two threads even after getting response from reply queue. PersistentQueueReplyManager JmsReplyManagerTimeoutChecker I am under the impression that once i get the response from jms inout these threads will be terminated.but i see that these threads are running

CAMEL -JMS Request TimeOut

2012-11-01 Thread ravi.4indra
Hi, I am seeing the below behaviour with camel-jms component. inOut(jms:queue:quename?replyTo=queue1requestTimeOut=3) to(direct:nextRoute); I think requestTimeOut is the time camel will wait to get response from the queue. But I noticed that the total timeout for the route is set to 3

Re: Camel Timeout on a route

2012-10-29 Thread ravi.4indra
I am still having that problem.I had removed responseContext,RequestContext from the inMessage and added a requestContext with a new ClientPolicy .Do i to remove any other headers? below is the code snippet exchange.getIn().removeHeader(Client.RESPONSE_CONTEXT);

Re: Camel Timeout on a route

2012-10-28 Thread ravi.4indra
Hi, I am using camel-CXF component.I am suspecting that the request context is being cached somewhere in the cxf/camel code thats the reason new timeout value is not honored. can you please provide a solution for this? Thanks Ravi -- View this message in context:

Re: Camel Timeout on a route

2012-10-28 Thread ravi.4indra
Hi Willem, I was able to set the timeout Dynamically FirstTime. But when i tried change the client policy somwhere in my route its not picking up the new value. is this the expected behaviour? Tanks Ravi -- View this message in context:

Re: Camel Timeout on a route

2012-10-28 Thread ravi.4indra
Also i dont have any default configuration. so the first time i set the timeout it will remain as my default timeout for all the endpoints? bean(mapper,changeTimeOut) to(cxf://webservice1) bean(mapper,changeTimeOut) to(cxf://webservice2) I noticed that webservice2 is using the timeout value set

Re: Camel Timeout on a route

2012-10-28 Thread ravi.4indra
Hi Willem, Thanks for sharing the information. I have two webservices call in a camel route. I am noticing that the timeout i have set for the first call is being used for the second web service call. even though i have changed the timeout in 3 step to less than the default timeout it is always

Re: Camel Timeout on a route

2012-10-27 Thread ravi.4indra
Hi, Is there a way to set timeout dynamically in camel-cxf component?. So do the total timeout of 60 seconds, if the first webservice call took 10 seconds then the timeout of second webservice call is 60-10 seconds. for this i need to set the timeout using exchange header. is it possible to do?

Re: Camel Timeout on a route

2012-10-26 Thread ravi.4indra
Hi Raul, can you please provide your inputs on the below piece of code. This method the uses the producer template asyncCallback to call the commonRoute.and i used the future handle to get the response. public void getDataUsingProducerTemplate(Exchange exchange) throws TimeoutException,

Camel Timeout on a route

2012-10-25 Thread ravi.4indra
Hi, Is there a way to specify timeout on a route. Example from(direct:route1) .to(bean:dosomething) .to(direct:commonRoute) now if the commonRoute takes more than n milliseconds i want to get a timeout exception. FYI I tried seda component I got the timeout exception after n seconds but the

Camel JMS Request Reply

2012-09-30 Thread ravi.4indra
Hi , I need some help with camel JMS Request reply (InOUT) I want my aggregation method to generate new exchange from replyMessage(it is the meesage in replyto Queue/response for my request message) and a dummy bean which returns a object. can the aggregationStartegy get the message from