working on #141 #142 #143

Author: phasenraum2010

src/main/java/org/woehlke/twitterwall/conf/TwitterProperties.java

@@ -27,6 +27,9 @@ public class TwitterProperties {
     @NotNull
     private Integer pageSize;
 
+    @NotNull
+    private Integer millisToWaitBetweenTwoApiCalls;
+
     @NotNull
     private String searchQuery;
 
@@ -77,4 +80,12 @@ public String getSearchQuery() {
     public void setSearchQuery(String searchQuery) {
         this.searchQuery = searchQuery;
     }
+
+    public Integer getMillisToWaitBetweenTwoApiCalls() {
+        return millisToWaitBetweenTwoApiCalls;
+    }
+
+    public void setMillisToWaitBetweenTwoApiCalls(Integer millisToWaitBetweenTwoApiCalls) {
+        this.millisToWaitBetweenTwoApiCalls = millisToWaitBetweenTwoApiCalls;
+    }
 }

src/main/java/org/woehlke/twitterwall/scheduled/mq/endoint/impl/UpdateTweetsImpl.java

@@ -59,10 +59,15 @@ public List<TweetFromTwitter> splitMessage(Message<TaskMessage> message) {
             hasNext = tweetTwitterIds.hasNext();
             worklistTwitterIds.addAll(tweetTwitterIds.getContent());
         }
+        int millisToWaitBetweenTwoApiCalls = twitterProperties.getMillisToWaitBetweenTwoApiCalls();
         for(Long tweetTwitterId : worklistTwitterIds){
             Tweet foundTweetFromTwitter = twitterApiService.findOneTweetById(tweetTwitterId);
             TweetFromTwitter result = new TweetFromTwitter(task.getId(),foundTweetFromTwitter);
             tweets.add(result);
+            try {
+                Thread.sleep(millisToWaitBetweenTwoApiCalls);
+            } catch (InterruptedException e) {
+            }
         }
         return tweets;
     }

src/main/java/org/woehlke/twitterwall/scheduled/mq/endoint/impl/UpdateUserProfilesFromMentionsImpl.java

@@ -73,12 +73,17 @@ public List<TwitterProfileMessage> splitMessage(Message<TaskMessage> message) {
             }
             pageRequest = pageRequest.next();
         }
+        int millisToWaitBetweenTwoApiCalls = twitterProperties.getMillisToWaitBetweenTwoApiCalls();
         for(String screenName:screenNames){
             TwitterProfile userProfile = twitterApiService.getUserProfileForScreenName(screenName);
             if(userProfile!=null){
                 TwitterProfileMessage userMsg = new TwitterProfileMessage(msgIn,userProfile);
                 userProfileList.add(userMsg);
             }
+            try {
+                Thread.sleep(millisToWaitBetweenTwoApiCalls);
+            } catch (InterruptedException e) {
+            }
         }
         return userProfileList;
     }

src/main/java/org/woehlke/twitterwall/scheduled/mq/endoint/impl/UpdateUserProfilesImpl.java

@@ -70,6 +70,7 @@ public List<TwitterProfileMessage> splitMessage(Message<TaskMessage> message) {
             worklistProfileTwitterIds.addAll(userProfileTwitterIds.getContent());
         }
         long number = worklistProfileTwitterIds.size();
+        int millisToWaitBetweenTwoApiCalls = twitterProperties.getMillisToWaitBetweenTwoApiCalls();
         for(Long userProfileTwitterId:worklistProfileTwitterIds){
             allLoop++;
             loopId++;
@@ -85,6 +86,10 @@ public List<TwitterProfileMessage> splitMessage(Message<TaskMessage> message) {
                 TwitterProfileMessage userMsg = new TwitterProfileMessage(msgIn,userProfile);
                 userProfileList.add(userMsg);
             }
+            try {
+                Thread.sleep(millisToWaitBetweenTwoApiCalls);
+            } catch (InterruptedException e) {
+            }
         }
         return userProfileList;
     }

src/main/resources/application.yml

@@ -66,6 +66,7 @@ twitter:
   #  consumerSecret: ${TWITTER_CONSUMER_SECRET}
   pageSize: ${TWITTER_PAGE_SIZE}
   searchQuery: ${TWITTER_SEARCH_TERM}
+  millisToWaitBetweenTwoApiCalls: 5000
 twitterwall:
   backend:
     twitter: