它似乎忽略了 ExchangePattern 你设定。您是否尝试将其设置为JMS URI activemq:queue:...&exchangePattern=InOut ?
ExchangePattern
activemq:queue:...&exchangePattern=InOut
我不确定你是否还需要定义 JMSReplyTo 消息上的标题或者当exchangePattern是InOut时自动完成此操作。
JMSReplyTo
使用 request 生产者的方法就是为了 InOut
request
InOut
以下代码适用于我:
def sendAndReceiveExtractionDetails(request:String, header: String) : String = { camel.createProducerTemplate() .sendBody("activemq:queue:extractor-jobs?requestTimeout=1400000", ExchangePattern.InOut, request).toString }