You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by mf...@apache.org on 2014/06/04 21:31:28 UTC

git commit: STREAMS-99 | updated method to be protected rather than private for easier extension

Repository: incubator-streams
Updated Branches:
  refs/heads/master 0ab4fb101 -> c4b36af75


STREAMS-99 | updated method to be protected rather than private for easier extension


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

Branch: refs/heads/master
Commit: c4b36af75a13987c8c8ad8c162be704107961343
Parents: 0ab4fb1
Author: mfranklin <mf...@apache.org>
Authored: Wed Jun 4 15:31:08 2014 -0400
Committer: mfranklin <mf...@apache.org>
Committed: Wed Jun 4 15:31:08 2014 -0400

----------------------------------------------------------------------
 .../streams/twitter/processor/FetchAndReplaceTwitterProcessor.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/c4b36af7/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/FetchAndReplaceTwitterProcessor.java
----------------------------------------------------------------------
diff --git a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/FetchAndReplaceTwitterProcessor.java b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/FetchAndReplaceTwitterProcessor.java
index 29775bb..7b4093f 100644
--- a/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/FetchAndReplaceTwitterProcessor.java
+++ b/streams-contrib/streams-provider-twitter/src/main/java/org/apache/streams/twitter/processor/FetchAndReplaceTwitterProcessor.java
@@ -155,7 +155,7 @@ public class FetchAndReplaceTwitterProcessor implements StreamsProcessor {
     }
 
     //Hardcore sleep to allow for catch up
-    private void sleepAndTryAgain(Activity doc, String originalId) {
+    protected void sleepAndTryAgain(Activity doc, String originalId) {
         try {
             //Attempt to fetchAndReplace with a backoff up to the limit then just reset the count and let the process continue
             if(retryCount < MAX_ATTEMPTS) {