On Wed, Mar 24, 2010 at 3:31 PM, Leen Toelen <[email protected]> wrote: > Hi, > > what I would like as a result is that the HTTP generates a 200 OK as > soon as possible, and if the ActiveMQ queue is being throttled I > generate a 503 Service Temporarily Unavailable. >
You have to ask at AMQ forum as its about its connection which can live reconnect and whatnot. There are some options you can set to adjust for that. Also something about sendAsync=false to have it return with fail faster. But all those options and whatnot is what the AMQ people know about. > Regards, > Leen > > On Wed, Mar 24, 2010 at 12:23 PM, Charles Moulliard > <[email protected]> wrote: >> Maybe, you should consider to use an async route : >> http://camel.apache.org/asynchronous-processing.html >> >> Kind regards, >> >> Charles Moulliard >> Senior Enterprise Architect >> Apache Camel Committer >> >> ***************************** >> blog : http://cmoulliard.blogspot.com >> twitter : http://twitter.com/cmoulliard >> Linkedlin : http://www.linkedin.com/in/charlesmoulliard >> >> Apache Camel Group : >> http://www.linkedin.com/groups?home=&gid=2447439&trk=anet_ug_hm >> >> >> On Wed, Mar 24, 2010 at 12:16 PM, Leen Toelen <[email protected]> wrote: >> >>> Hi, >>> >>> I have an HTTP endpoint that submits messages to an ActiveMQ queue. >>> When the consumer gets slow, the Queue is throttled and the HTTP call >>> hangs infinitely. Is there a way to tell the broker that if a JMS >>> message is not accepted within a timeout, the exchange is interrupted >>> and the HTTP endpoint returns an HTTP error? I tried RequestTimeout >>> but that does not seem to do what I expected. >>> >>> HttpEndpoint httpEndpoint = (HttpEndpoint) >>> endpoint("jetty:http://0.0.0.0:8162/queue";); >>> >>> JmsEndpoint topic = (JmsEndpoint) endpoint("activemq:topic:MyTopic"); >>> topic.setReceiveTimeout(5000); >>> topic.setRequestTimeout(5000); >>> >>> from(httpEndpoint).inOnly(topic); >>> >>> Regards, >>> Leen >>> >> > -- Claus Ibsen Apache Camel Committer Author of Camel in Action: http://www.manning.com/ibsen/ Open Source Integration: http://fusesource.com Blog: http://davsclaus.blogspot.com/ Twitter: http://twitter.com/davsclaus
