当我使用jms来使用Ibm Mq时,如何停止apache camel中的线程?我正在使用jms,稍后我必须使用和Rest api,但我得到超时错误,因为jms的线程继续,而不需要使用Rest api。这是我的路线:
from(Rutas.CONSUME_CUENTA_DETALLE)
.routeId("CONSUME_CUENTA_DETALLE")
.removeHeaders("*")
.setHeader("CamelJmsDestinationName",
constant("queue:///"+colaCuentaDetalle+"?targetClient=1"))
.to("jms://queue:" + colaCuentaDetalle
+"?exchangePattern=InOut"
+"&useMessageIDAsCorrelationID=true"
+"&replyToType=Temporary"
+"&requestTimeout=3s"
+"&asyncStopListener=true"
+"&cacheLevelName=CACHE_CONSUMER")
.id("Cuenta_detalle")
.removeHeader("*")
.to(Rutas.VALIDATE_RESPONSE_CUENTA_DETALLE)
.end();
1条答案
按热度按时间vfwfrxfs1#
我看不出
Rutas.VALIDATE_RESPONSE_CUENTA_DETALLE
处的使用者是什么类型,但是如果您将其设置为SEDA
使用者,它将使用自己的线程池来处理消息,并将JMS使用者线程返回到自己的池中。