streams-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mfrank...@apache.org
Subject [7/8] git commit: STREAMS-144 | Perserved interupted state in data collector
Date Mon, 25 Aug 2014 16:42:54 GMT
STREAMS-144 | Perserved interupted state in data collector


Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/8d25fa4c
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/8d25fa4c
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/8d25fa4c

Branch: refs/heads/master
Commit: 8d25fa4c7aec3f4a746f09cd8b0a35a8059d1159
Parents: 96bdf95
Author: Ryan Ebanks <rebanks@Informations-MacBook-Pro-3.local>
Authored: Wed Aug 20 13:26:20 2014 -0500
Committer: Ryan Ebanks <rebanks@Informations-MacBook-Pro-3.local>
Committed: Wed Aug 20 13:26:20 2014 -0500

----------------------------------------------------------------------
 .../apache/streams/instagram/provider/InstagramDataCollector.java  | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/8d25fa4c/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/InstagramDataCollector.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/InstagramDataCollector.java
b/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/InstagramDataCollector.java
index d7a98fc..97451f0 100644
--- a/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/InstagramDataCollector.java
+++ b/streams-contrib/streams-provider-instagram/src/main/java/org/apache/streams/instagram/provider/InstagramDataCollector.java
@@ -117,6 +117,8 @@ public abstract class InstagramDataCollector<T> implements Runnable
{
         for (User user : this.config.getUsersInfo().getUsers()) {
             try {
                 collectInstagramDataForUser(user);
+            } catch (InterruptedException ie) {
+                Thread.currentThread().interrupt();
             } catch (Exception e) {
                 LOGGER.error("Exception thrown while polling for user, {}, skipping user.",
user.getUserId());
                 LOGGER.error("Exception thrown while polling for user : ", e);


Mime
View raw message