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/05 20:54:19 UTC
[32/52] [abbrv] git commit: Fixed endpoint issue in
TwitterStreamProvider
Fixed endpoint issue in TwitterStreamProvider
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/10923617
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/10923617
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/10923617
Branch: refs/heads/sblackmon
Commit: 10923617ec15830dee7eb78d2a4e334387d8c290
Parents: 4a2ca2d
Author: Robert Douglas <rd...@w2odigital.com>
Authored: Fri Apr 4 13:14:11 2014 -0500
Committer: Robert Douglas <rd...@w2odigital.com>
Committed: Fri Apr 4 13:14:11 2014 -0500
----------------------------------------------------------------------
.../streams/twitter/provider/TwitterStreamProvider.java | 11 +++++++++--
1 file changed, 9 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/10923617/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamProvider.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamProvider.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamProvider.java
index 39e1ad5..3df7d02 100644
--- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamProvider.java
+++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/provider/TwitterStreamProvider.java
@@ -156,11 +156,15 @@ public class TwitterStreamProvider implements StreamsProvider, Serializable {
Optional<List<Long>> follow = Optional.fromNullable(config.getFollow());
if( track.isPresent() || follow.isPresent() ) {
+ LOGGER.debug("***\tPRESENT\t***");
StatusesFilterEndpoint statusesFilterEndpoint = new StatusesFilterEndpoint();
- if( track.isPresent() )
+ if( track.isPresent() ) {
statusesFilterEndpoint.trackTerms(track.get());
- if( follow.isPresent() )
+ }
+ else {
statusesFilterEndpoint.followings(follow.get());
+ }
+ this.endpoint = statusesFilterEndpoint;
} else {
endpoint = new StatusesSampleEndpoint();
}
@@ -201,6 +205,8 @@ public class TwitterStreamProvider implements StreamsProvider, Serializable {
return;
}
+ LOGGER.debug("host={}\tendpoint={}\taut={}", new Object[] {hosebirdHosts,endpoint,auth});
+
client = new ClientBuilder()
.name("apache/streams/streams-contrib/streams-provider-twitter")
.hosts(hosebirdHosts)
@@ -208,6 +214,7 @@ public class TwitterStreamProvider implements StreamsProvider, Serializable {
.authentication(auth)
.processor(new StringDelimitedProcessor(inQueue))
.build();
+
}
@Override