CAMEL-10527: camel-mail - Option skipFailedMessage should catch all exceptions
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/7a4ab4f2 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/7a4ab4f2 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/7a4ab4f2 Branch: refs/heads/camel-2.18.x Commit: 7a4ab4f2a0ece56e99894960bbfad26e1f73752e Parents: 923cd93 Author: Claus Ibsen <davscl...@apache.org> Authored: Fri Nov 25 14:14:04 2016 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Fri Nov 25 14:14:39 2016 +0100 ---------------------------------------------------------------------- .../main/java/org/apache/camel/component/mail/MailConsumer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/7a4ab4f2/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailConsumer.java b/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailConsumer.java index 1efa42d..05047e8 100644 --- a/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailConsumer.java +++ b/components/camel-mail/src/main/java/org/apache/camel/component/mail/MailConsumer.java @@ -287,7 +287,7 @@ public class MailConsumer extends ScheduledBatchPollingConsumer { try { Message msg = folder.getMessage(i); msgs.add(msg); - } catch (MessagingException e) { + } catch (Exception e) { if (skipFailedMessage) { LOG.debug("Skipping failed message at index " + i + " due " + e.getMessage(), e); } else if (handleFailedMessage) { @@ -367,7 +367,7 @@ public class MailConsumer extends ScheduledBatchPollingConsumer { LOG.debug("Skipping message as it was flagged as deleted: {}", MailUtils.dumpMessage(message)); } } - } catch (MessagingException e) { + } catch (Exception e) { if (skipFailedMessage) { LOG.debug("Skipping failed message at index " + i + " due " + e.getMessage(), e); } else if (handleFailedMessage) {
