You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by sb...@apache.org on 2014/05/13 17:23:02 UTC
[12/14] git commit: increasing queue size and initializing twitter
during prepare
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 <sb...@w2odigital.com>
Authored: Thu May 8 19:27:39 2014 -0500
Committer: sblackmon <sb...@w2odigital.com>
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();
}