Croway commented on code in PR #22117:
URL: https://github.com/apache/camel/pull/22117#discussion_r3026762929
##########
components/camel-paho/src/main/java/org/apache/camel/component/paho/PahoConsumer.java:
##########
@@ -154,13 +154,15 @@ public void onComplete(Exchange exchange) {
try {
PahoConsumer.this.client.messageArrivedComplete(mqttMessage.getId(),
mqttMessage.getQos());
} catch (MqttException e) {
- LOG.warn("Failed to commit message with ID {} due to
MqttException.", mqttMessage.getId());
+ getExceptionHandler().handleException(
+ "Error acknowledging MQTT message with ID: " +
mqttMessage.getId(),
+ exchange, e);
}
}
@Override
public void onFailure(Exchange exchange) {
- LOG.error("Rollback due to error processing Exchange ID:
{}", exchange.getExchangeId(),
+ LOG.debug("Rollback due to error processing Exchange ID:
{}", exchange.getExchangeId(),
Review Comment:
why `debug` instead of `error`?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
