Repository: camel Updated Branches: refs/heads/camel-2.12.x 2da223d6e -> 9195ef645 refs/heads/camel-2.13.x b1f3fd219 -> 06b7d5c87 refs/heads/master a25dbec5c -> c43f8e400
CAMEL-7411: EventDrivenPollingConsumer can lose exchanges when the internal queue is full Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/c43f8e40 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/c43f8e40 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/c43f8e40 Branch: refs/heads/master Commit: c43f8e40010444c144efe70c43c26b5110e38594 Parents: a25dbec Author: Claus Ibsen <davscl...@apache.org> Authored: Thu May 8 07:08:48 2014 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Thu May 8 07:08:48 2014 +0200 ---------------------------------------------------------------------- .../java/org/apache/camel/impl/EventDrivenPollingConsumer.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/c43f8e40/camel-core/src/main/java/org/apache/camel/impl/EventDrivenPollingConsumer.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/impl/EventDrivenPollingConsumer.java b/camel-core/src/main/java/org/apache/camel/impl/EventDrivenPollingConsumer.java index 428610e..22efbec 100644 --- a/camel-core/src/main/java/org/apache/camel/impl/EventDrivenPollingConsumer.java +++ b/camel-core/src/main/java/org/apache/camel/impl/EventDrivenPollingConsumer.java @@ -18,7 +18,7 @@ package org.apache.camel.impl; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.BlockingQueue; -import java.util.concurrent.LinkedBlockingDeque; +import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.RejectedExecutionException; import java.util.concurrent.TimeUnit; @@ -55,7 +55,7 @@ public class EventDrivenPollingConsumer extends PollingConsumerSupport implement super(endpoint); this.queueCapacity = queueSize; if (queueSize <= 0) { - this.queue = new LinkedBlockingDeque<Exchange>(); + this.queue = new LinkedBlockingQueue<Exchange>(); } else { this.queue = new ArrayBlockingQueue<Exchange>(queueSize); }
