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
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;
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:
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
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:
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
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
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
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
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)
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
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
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
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
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
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);
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:
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:
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
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
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?
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,
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
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
24 matches
Mail list logo