java - receive() 之后 PollingConsumer 模板中的信号异常

Question

在 Apache Camel 中使用 PollingConsumer 模板进行 Exchange Exchange = Consumer.receive(); 后是否可以发出错误信号？例如，如果您从 bean 处理器抛出错误，Camel 会在控制台中打印堆栈跟踪并停止路由。是否可以使用 PollingConsumer 执行相同的操作，可能会再次重试消息？有这个PollingConsumerPollStrategy，但它看起来像是用于在receive()之前进行错误处理。

Answer 1

没有轮询消费者是基于队列的交换，因此它返回已检索到成功交换的交换。您可以使用带有超时的接收，如果在该时间内无法检索交换，则会抛出超时异常。

如果您想要异常(exception)，请使用 Consumer 而不是 PollingConsumer。