You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by mf...@apache.org on 2014/05/27 15:44:00 UTC
[6/9] git commit: STREAMS-96 | Changed constructQueue method to
protected and added constant: MAX_NUMBER_WAITING
STREAMS-96 | Changed constructQueue method to protected and added constant: MAX_NUMBER_WAITING
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/ec5d3482
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/ec5d3482
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/ec5d3482
Branch: refs/heads/master
Commit: ec5d3482ea03452c9830815c1e0c9b4221d80f2d
Parents: 189d443
Author: Robert Douglas <rd...@w2odigital.com>
Authored: Thu May 22 15:42:05 2014 -0500
Committer: mfranklin <mf...@apache.org>
Committed: Tue May 27 09:33:21 2014 -0400
----------------------------------------------------------------------
.../streams/twitter/provider/TwitterTimelineProvider.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/ec5d3482/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterTimelineProvider.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterTimelineProvider.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterTimelineProvider.java
index 50bb8c0..b6e4332 100644
--- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterTimelineProvider.java
+++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterTimelineProvider.java
@@ -58,6 +58,7 @@ public class TwitterTimelineProvider implements StreamsProvider, Serializable {
public final static String STREAMS_ID = "TwitterTimelineProvider";
private final static Logger LOGGER = LoggerFactory.getLogger(TwitterTimelineProvider.class);
+ public static final int MAX_NUMBER_WAITING = 10000;
private TwitterStreamConfiguration config;
@@ -228,8 +229,8 @@ public class TwitterTimelineProvider implements StreamsProvider, Serializable {
}
- private Queue<StreamsDatum> constructQueue() {
- return Queues.synchronizedQueue(new LinkedBlockingQueue<StreamsDatum>(10000));
+ protected Queue<StreamsDatum> constructQueue() {
+ return Queues.synchronizedQueue(new LinkedBlockingQueue<StreamsDatum>(MAX_NUMBER_WAITING));
}
public StreamsResultSet readNew(BigInteger sequence) {