davsclaus commented on code in PR #28133:
URL: https://github.com/apache/camel/pull/28133#discussion_r4321905382
##########
components/camel-minio/src/main/java/org/apache/camel/component/minio/MinioConsumer.java:
##########
@@ -324,10 +368,18 @@ public void onDone(Exchange exchange) {
skipped++;
continue;
}
- LOG.warn("Error getting MinioObject due: {}",
e.getMessage());
- // this and the remaining exchanges of the batch are not
processed
- releaseInProgress(srcObjectName, exchanges);
- throw e;
+ if (objectNameConfigured()) {
+ LOG.warn("Error getting MinioObject due: {}",
e.getMessage());
+ // the one object of the poll is not processed
+ releaseInProgress(srcObjectName, exchanges);
+ throw e;
+ }
+ // a failure to get one listed object does not stop the
other objects of the batch: the object is
+ // skipped, and a later poll tries it again
+ inProgress.remove(srcObjectName);
+ skipped++;
+ failures.put(srcObjectName, e);
+ continue;
Review Comment:
Nit: the exchange of an object whose get fails is never released to the
exchange factory. camel-aws2-s3 (CAMEL-25558) and camel-google-storage call
`releaseExchange(exchange, false)` on this path.
--
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]
