Added javadocs and set default queue size to 500
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/91a0f9a6 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/91a0f9a6 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/91a0f9a6 Branch: refs/heads/master Commit: 91a0f9a6799135619d2688699dcd71cfd3321138 Parents: 0d20773 Author: Ryan Ebanks <[email protected]> Authored: Wed Oct 8 12:57:24 2014 -0500 Committer: Ryan Ebanks <[email protected]> Committed: Wed Oct 8 12:57:24 2014 -0500 ---------------------------------------------------------------------- .../streams/local/builders/LocalStreamBuilder.java | 15 +++++++++------ 1 file changed, 9 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/91a0f9a6/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java ---------------------------------------------------------------------- diff --git a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java index 4606aa7..57f3aa4 100644 --- a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java +++ b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java @@ -44,6 +44,7 @@ import java.util.concurrent.TimeUnit; public class LocalStreamBuilder implements StreamBuilder { private static final Logger LOGGER = org.slf4j.LoggerFactory.getLogger(LocalStreamBuilder.class); + private static final int DEFAULT_QUEUE_SIZE = 500; public static final String TIMEOUT_KEY = "TIMEOUT"; private Map<String, StreamComponent> providers; @@ -60,22 +61,23 @@ public class LocalStreamBuilder implements StreamBuilder { private int maxQueueCapacity; /** - * + * Creates a local stream builder with no config object and default maximum internal queue size of 500 */ public LocalStreamBuilder(){ - this(-1, null); + this(DEFAULT_QUEUE_SIZE, null); } /** - * + * Creates a local stream builder with a config object and default maximum internal queue size of 500 * @param streamConfig */ public LocalStreamBuilder(Map<String, Object> streamConfig) { - this(-1, streamConfig); + this(DEFAULT_QUEUE_SIZE, streamConfig); } /** - * + * Creates a local stream builder with no config object. If maxQueueCapacity is less than 1 the queue is + * unbounded. * @param maxQueueCapacity */ public LocalStreamBuilder(int maxQueueCapacity) { @@ -83,7 +85,8 @@ public class LocalStreamBuilder implements StreamBuilder { } /** - * + * Creates a local stream builder with a config object. If maxQueueCapacity is less than 1 the queue is + * unbounded. * @param maxQueueCapacity * @param streamConfig */
