Обмен сообщениями Apache Camel не ждет ответа

Question

У меня следующий код для публикации сообщения в activeMQ и чтения ответа через exchange.Но код, кажется, возвращается мгновенно и не ждет ответа.Не могли бы вы указать, что не так со следующим кодом Scala.

def sendAndReceiveExtractionDetails(request:String, header: String) : String = {
    val exchange: DefaultExchange = new DefaultExchange(camel, ExchangePattern.InOut)
    exchange.getIn.setBody(request)
    exchange.getIn.setHeader("meshId", header)
    producer.send("activemq:queue:extractor-jobs?requestTimeout=1400000", exchange)
    val out: apache.camel.Message = exchange.getOut()
    out.getBody().toString
}

Answer 1

Используйте метод request для производителя, как для InOut

Answer 2

У меня работает следующий код:

  def sendAndReceiveExtractionDetails(request:String, header: String) : String = {
    camel.createProducerTemplate()
      .sendBody("activemq:queue:extractor-jobs?requestTimeout=1400000", ExchangePattern.InOut, request).toString
  }

Answer 3

Кажется, игнорируется ExchangePattern, который вы установили.Вы пытались установить его на свой JMS URI как activemq:queue:...&exchangePattern=InOut?

Я не уверен, нужно ли вам также определять заголовок JMSReplyTo в сообщении или это делается автоматически, когда exchangePattern имеет значение InOut.