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/master Commit: 10923617ec15830dee7eb78d2a4e334387d8c290 Parents: 4a2ca2d Author: Robert Douglas <[email protected]> Authored: Fri Apr 4 13:14:11 2014 -0500 Committer: Robert Douglas <[email protected]> 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
