Repository: camel Updated Branches: refs/heads/master 9af26ef71 -> 6651c1b0b
Polished Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/13f5b04d Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/13f5b04d Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/13f5b04d Branch: refs/heads/master Commit: 13f5b04d21a324bc7d25d17fd3f3446c52b83d8f Parents: 9af26ef Author: Claus Ibsen <davscl...@apache.org> Authored: Mon May 29 14:47:41 2017 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Mon May 29 14:47:41 2017 +0200 ---------------------------------------------------------------------- .../apache/camel/component/seda/ArrayBlockingQueueFactory.java | 3 ++- .../org/apache/camel/component/seda/BlockingQueueFactory.java | 3 ++- .../apache/camel/component/seda/LinkedBlockingQueueFactory.java | 2 +- .../apache/camel/component/seda/PriorityBlockingQueueFactory.java | 1 + 4 files changed, 6 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/13f5b04d/camel-core/src/main/java/org/apache/camel/component/seda/ArrayBlockingQueueFactory.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/component/seda/ArrayBlockingQueueFactory.java b/camel-core/src/main/java/org/apache/camel/component/seda/ArrayBlockingQueueFactory.java index b075467..d9fd3e0 100644 --- a/camel-core/src/main/java/org/apache/camel/component/seda/ArrayBlockingQueueFactory.java +++ b/camel-core/src/main/java/org/apache/camel/component/seda/ArrayBlockingQueueFactory.java @@ -16,17 +16,18 @@ */ package org.apache.camel.component.seda; - import java.util.concurrent.ArrayBlockingQueue; /** * Implementation of {@link BlockingQueueFactory} producing {@link java.util.concurrent.ArrayBlockingQueue} */ public class ArrayBlockingQueueFactory<E> implements BlockingQueueFactory<E> { + /** * Capacity used when none provided */ private int defaultCapacity = 50; + /** * Lock fairness. null means default fairness */ http://git-wip-us.apache.org/repos/asf/camel/blob/13f5b04d/camel-core/src/main/java/org/apache/camel/component/seda/BlockingQueueFactory.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/component/seda/BlockingQueueFactory.java b/camel-core/src/main/java/org/apache/camel/component/seda/BlockingQueueFactory.java index 0d69433..89f0fb8 100644 --- a/camel-core/src/main/java/org/apache/camel/component/seda/BlockingQueueFactory.java +++ b/camel-core/src/main/java/org/apache/camel/component/seda/BlockingQueueFactory.java @@ -16,7 +16,6 @@ */ package org.apache.camel.component.seda; - import java.util.concurrent.BlockingQueue; import org.apache.camel.Exchange; @@ -25,11 +24,13 @@ import org.apache.camel.Exchange; * @param <E> Element type, usually {@link Exchange} */ public interface BlockingQueueFactory<E> { + /** * Create a new {@link java.util.concurrent.BlockingQueue} with default capacity * @return New {@link java.util.concurrent.BlockingQueue} */ BlockingQueue<E> create(); + /** * Create a new {@link java.util.concurrent.BlockingQueue} with given capacity * @return New {@link java.util.concurrent.BlockingQueue} http://git-wip-us.apache.org/repos/asf/camel/blob/13f5b04d/camel-core/src/main/java/org/apache/camel/component/seda/LinkedBlockingQueueFactory.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/component/seda/LinkedBlockingQueueFactory.java b/camel-core/src/main/java/org/apache/camel/component/seda/LinkedBlockingQueueFactory.java index 096cd5b..b75ab39 100644 --- a/camel-core/src/main/java/org/apache/camel/component/seda/LinkedBlockingQueueFactory.java +++ b/camel-core/src/main/java/org/apache/camel/component/seda/LinkedBlockingQueueFactory.java @@ -16,13 +16,13 @@ */ package org.apache.camel.component.seda; - import java.util.concurrent.LinkedBlockingQueue; /** * Implementation of {@link BlockingQueueFactory} producing {@link java.util.concurrent.LinkedBlockingQueue} */ public class LinkedBlockingQueueFactory<E> implements BlockingQueueFactory<E> { + @Override public LinkedBlockingQueue<E> create() { return new LinkedBlockingQueue<E>(); http://git-wip-us.apache.org/repos/asf/camel/blob/13f5b04d/camel-core/src/main/java/org/apache/camel/component/seda/PriorityBlockingQueueFactory.java ---------------------------------------------------------------------- diff --git a/camel-core/src/main/java/org/apache/camel/component/seda/PriorityBlockingQueueFactory.java b/camel-core/src/main/java/org/apache/camel/component/seda/PriorityBlockingQueueFactory.java index a1bd36f..377cb83 100644 --- a/camel-core/src/main/java/org/apache/camel/component/seda/PriorityBlockingQueueFactory.java +++ b/camel-core/src/main/java/org/apache/camel/component/seda/PriorityBlockingQueueFactory.java @@ -24,6 +24,7 @@ import java.util.concurrent.PriorityBlockingQueue; * Implementation of {@link BlockingQueueFactory} producing {@link java.util.concurrent.PriorityBlockingQueue} */ public class PriorityBlockingQueueFactory<E> implements BlockingQueueFactory<E> { + /** * Comparator used to sort exchanges */
