CAMEL-8085 Break iteration if interrupted or barrier is broken
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/0f7ed7b0 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/0f7ed7b0 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/0f7ed7b0 Branch: refs/heads/master Commit: 0f7ed7b0a5bcc3f853b1929f9352b49530b308d7 Parents: a18f05c Author: Ivan Vasylyev <vasilie...@gmail.com> Authored: Mon Dec 1 14:19:29 2014 +0200 Committer: Willem Jiang <willem.ji...@gmail.com> Committed: Tue Dec 2 10:52:44 2014 +0800 ---------------------------------------------------------------------- .../main/java/org/apache/camel/component/kafka/KafkaConsumer.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/0f7ed7b0/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java index 4e3cd0a..2711bfa 100644 --- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java +++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java @@ -140,8 +140,10 @@ public class KafkaConsumer extends DefaultConsumer { processed = 0; } catch (InterruptedException e) { LOG.error(e.getMessage(), e); + break; } catch (BrokenBarrierException e) { LOG.error(e.getMessage(), e); + break; } catch (TimeoutException e) { LOG.error(e.getMessage(), e); }
