receive() 后 PollingConsumer 模板中的异常信号
Signal exception in a PollingConsumer template after receive()
在 Apache Camel 中使用 PollingConsumer
模板可以在 Exchange exchange = consumer.receive();
之后发出错误信号?例如,如果您从 bean 处理器中抛出错误,Camel 会在控制台中打印堆栈跟踪并停止路由。是否可以使用 PollingConsumer 做同样的事情,可能会再次重试该消息?有这个 PollingConsumerPollStrategy
但它看起来像是用于错误处理 before receive().
没有轮询消费者是基于队列的交换,因此它 returns 是一个成功检索到交换的交换。如果在该时间内无法检索交换,您可以使用 receive with timeout 抛出超时异常。
如果您想要例外,请使用 Consumer
而不是 PollingConsumer
。
在 Apache Camel 中使用 PollingConsumer
模板可以在 Exchange exchange = consumer.receive();
之后发出错误信号?例如,如果您从 bean 处理器中抛出错误,Camel 会在控制台中打印堆栈跟踪并停止路由。是否可以使用 PollingConsumer 做同样的事情,可能会再次重试该消息?有这个 PollingConsumerPollStrategy
但它看起来像是用于错误处理 before receive().
没有轮询消费者是基于队列的交换,因此它 returns 是一个成功检索到交换的交换。如果在该时间内无法检索交换,您可以使用 receive with timeout 抛出超时异常。
如果您想要例外,请使用 Consumer
而不是 PollingConsumer
。