Camel ApacheMQ->AHC行为（阻塞？）

Question

我刚开始使用Apache Camel，我对异步http客户机(AHC)的看似违反直觉的默认行为很好奇。在使用来自ActiveMQ的消息时，我无法让它以非阻塞的方式运行。

我的路线如下所示：

@Component
public class Broadcaster extends RouteBuilder {

  @Override
  public void configure() throws Exception {
    errorHandler(deadLetterChannel("activemq:failed.messages"));

    from("activemq:outbound.messages")
    .setExchangePattern(ExchangePattern.InOnly)
    .recipientList(simple("ahc:${in.header[PublishDestination]}"))
    .end();
  }
}

我将几条消息排队，其中一半发送到延迟的web服务器，另一半发送到正常的web服务器。我希望看到快速服务器立即消耗所有正常的消息，而缓慢的消息随着时间的推移逐渐消耗。但是，这是在快速web服务器上观察到的行为：

00:24:02.585, <hello>World</hello>
00:24:03.622, <hello>World</hello>
00:24:04.640, <hello>World</hello>
00:24:05.658, <hello>World</hello>

正如您所看到的，每个记录的请求之间正好有一秒钟，这与慢速服务器上人为的1秒延迟相对应。根据路由定时，JMS使用者在使用队列中的下一条消息之前，似乎正在等待AHC完成：

Processor                                 Elapsed (ms)
[activemq://outbound.messages           ] [      1020]
[setExchangePattern[InOnly]             ] [         0]
[ahc:${in.header[PublishDestination]}}  ] [      1018]

在这些情况下，我应该显式地使用异步生成器并编写回调处理程序吗？还是我还遗漏了什么？谢谢！

Answer 1

嗯，我想是RTFM的例子，尽管我ActiveMQ页面在endpoint配置可用的属性方面还有很多不足之处。可能应该有一张纸条来说大部分（全部？）ActiveMQ组件也可以使用JMS配置选项。在任何情况下，解决方案都是如下定义消费者：

from("activemq:outbound.messages?asyncConsumer=true")