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
