Return-Path: X-Original-To: apmail-streams-commits-archive@minotaur.apache.org Delivered-To: apmail-streams-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 50D2511A5A for ; Mon, 11 Aug 2014 22:53:29 +0000 (UTC) Received: (qmail 87891 invoked by uid 500); 11 Aug 2014 22:53:29 -0000 Delivered-To: apmail-streams-commits-archive@streams.apache.org Received: (qmail 87845 invoked by uid 500); 11 Aug 2014 22:53:29 -0000 Mailing-List: contact commits-help@streams.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@streams.incubator.apache.org Delivered-To: mailing list commits@streams.incubator.apache.org Received: (qmail 87829 invoked by uid 99); 11 Aug 2014 22:53:29 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 11 Aug 2014 22:53:29 +0000 X-ASF-Spam-Status: No, hits=-2000.7 required=5.0 tests=ALL_TRUSTED,RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.3] (HELO mail.apache.org) (140.211.11.3) by apache.org (qpsmtpd/0.29) with SMTP; Mon, 11 Aug 2014 22:53:04 +0000 Received: (qmail 87552 invoked by uid 99); 11 Aug 2014 22:53:02 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 11 Aug 2014 22:53:02 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id E7C72814791; Mon, 11 Aug 2014 22:53:01 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: sblackmon@apache.org To: commits@streams.incubator.apache.org Date: Mon, 11 Aug 2014 22:53:07 -0000 Message-Id: <49eba29b803448739b54228db82baff0@git.apache.org> In-Reply-To: <4d51432722d64549bdc6067b18d6cb5f@git.apache.org> References: <4d51432722d64549bdc6067b18d6cb5f@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [07/15] git commit: if no ids are present, poll the logged-in user X-Virus-Checked: Checked by ClamAV on apache.org if no ids are present, poll the logged-in user Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/e0cb5ec2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/e0cb5ec2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/e0cb5ec2 Branch: refs/heads/master Commit: e0cb5ec25c6a58b45684b77935ddd57ec503a592 Parents: e8511ad Author: sblackmon Authored: Mon Jul 21 15:09:46 2014 -0500 Committer: sblackmon Committed: Mon Jul 21 15:09:46 2014 -0500 ---------------------------------------------------------------------- .../provider/FacebookUserstreamProvider.java | 24 ++++++++++++++------ 1 file changed, 17 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/e0cb5ec2/streams-contrib/streams-provider-facebook/src/main/java/com/facebook/provider/FacebookUserstreamProvider.java ---------------------------------------------------------------------- diff --git a/streams-contrib/streams-provider-facebook/src/main/java/com/facebook/provider/FacebookUserstreamProvider.java b/streams-contrib/streams-provider-facebook/src/main/java/com/facebook/provider/FacebookUserstreamProvider.java index af7868b..b0bf082 100644 --- a/streams-contrib/streams-provider-facebook/src/main/java/com/facebook/provider/FacebookUserstreamProvider.java +++ b/streams-contrib/streams-provider-facebook/src/main/java/com/facebook/provider/FacebookUserstreamProvider.java @@ -142,10 +142,17 @@ public class FacebookUserstreamProvider implements StreamsProvider, Serializable for( String id : configuration.getInfo()) { executor.submit(new FacebookFeedPollingTask(this, id)); } + running.set(true); } else { - executor.submit(new FacebookFeedPollingTask(this)); + try { + String id = client.getMe().getId(); + executor.submit(new FacebookFeedPollingTask(this, id)); + running.set(true); + } catch (FacebookException e) { + LOGGER.error(e.getMessage()); + running.set(false); + } } - running.set(true); } public StreamsResultSet readCurrent() { @@ -279,14 +286,12 @@ public class FacebookUserstreamProvider implements StreamsProvider, Serializable while (provider.isRunning()) { ResponseList postResponseList; try { - if( id != null ) - postResponseList = client.getFeed(id); - else - postResponseList = client.getHome(); + postResponseList = client.getFeed(id); Set update = Sets.newHashSet(postResponseList); Set repeats = Sets.intersection(priorPollResult, Sets.newHashSet(update)); Set entrySet = Sets.difference(update, repeats); + LOGGER.debug(this.id + " response: " + update.size() + " previous: " + repeats.size() + " new: " + entrySet.size()); for (Post item : entrySet) { String json = DataObjectFactory.getRawJSON(item); org.apache.streams.facebook.Post post = mapper.readValue(json, org.apache.streams.facebook.Post.class); @@ -299,9 +304,14 @@ public class FacebookUserstreamProvider implements StreamsProvider, Serializable } } priorPollResult = update; - Thread.sleep(configuration.getPollIntervalMillis()); } catch (Exception e) { e.printStackTrace(); + } finally { + try { + Thread.sleep(configuration.getPollIntervalMillis()); + } catch (InterruptedException e) { + Thread.currentThread().interrupt(); + } } } }