increasing queue size and initializing twitter during prepare
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/64cd1227 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/64cd1227 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/64cd1227 Branch: refs/heads/master Commit: 64cd1227caba30021f1cfc0d19e5521ce4c80cf4 Parents: 87bd8a3 Author: sblackmon <[email protected]> Authored: Thu May 8 19:27:39 2014 -0500 Committer: sblackmon <[email protected]> Committed: Thu May 8 19:27:39 2014 -0500 ---------------------------------------------------------------------- .../apache/streams/twitter/provider/TwitterTimelineProvider.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/64cd1227/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 3799737..e4b0460 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 @@ -54,7 +54,7 @@ public class TwitterTimelineProvider implements StreamsProvider, Serializable { this.config = config; } - protected final Queue<StreamsDatum> providerQueue = Queues.synchronizedQueue(new ArrayBlockingQueue<StreamsDatum>(500)); + protected final Queue<StreamsDatum> providerQueue = Queues.synchronizedQueue(new ArrayBlockingQueue<StreamsDatum>(5000)); protected int idsCount; protected Twitter client; @@ -245,6 +245,7 @@ public class TwitterTimelineProvider implements StreamsProvider, Serializable { jsonStoreEnabled = Optional.fromNullable(new Boolean(Boolean.parseBoolean(config.getJsonStoreEnabled()))).or(true); includeEntitiesEnabled = Optional.fromNullable(new Boolean(Boolean.parseBoolean(config.getIncludeEntities()))).or(true); + client = getTwitterClient(); }
