1515@ Component
1616public class ScheduledTasks {
1717
18- @ Scheduled (fixedRate = FIXED_RATE_FOR_SCHEDULAR_FETCH_TWEETS )
18+ @ Scheduled (initialDelay = TEN_SECONDS , fixedRate = FIXED_RATE_FOR_SCHEDULAR_FETCH_TWEETS )
1919 public void fetchTweetsFromTwitterSearch () {
2020 String msg = "fetch Tweets From TwitterSearch " ;
2121 if (schedulerProperties .getAllowUpdateTweets () && !schedulerProperties .getSkipFortesting ()) {
@@ -24,25 +24,25 @@ public void fetchTweetsFromTwitterSearch() {
2424 }
2525 }
2626
27- @ Scheduled (fixedRate = FIXED_RATE_FOR_SCHEDULAR_UPDATE_TWEETS )
28- public void updateTweets () {
29- String msg = "update Tweets " ;
30- if (schedulerProperties .getAllowUpdateTweets () && !schedulerProperties .getSkipFortesting ()){
31- Task task = asyncStartTask .updateTweets ();
27+ @ Scheduled (initialDelay = TEN_SECONDS * 2 , fixedRate = FIXED_RATE_FOR_SCHEDULAR_FETCH_USER_LIST )
28+ public void fetchUsersFromDefinedUserList () {
29+ String msg = "fetch Users from Defined User List " ;
30+ if (schedulerProperties .getFetchUserListAllow () && !schedulerProperties .getSkipFortesting ()) {
31+ Task task = asyncStartTask .fetchUsersFromList ();
3232 log .info (msg + "SCHEDULED: task " +task .getUniqueId ());
3333 }
3434 }
3535
36- @ Scheduled (fixedRate = FIXED_RATE_FOR_SCHEDULAR_UPDATE_USER )
37- public void updateUserProfiles () {
38- String msg = "update User Profiles " ;
39- if (schedulerProperties .getAllowUpdateUserProfiles () && !schedulerProperties .getSkipFortesting ()) {
40- Task task = asyncStartTask .updateUsers ();
36+ @ Scheduled (initialDelay = TEN_SECONDS * 3 , fixedRate = FIXED_RATE_FOR_SCHEDULAR_REMOVE_OLD_DATA_FROM_STORAGE )
37+ public void removeOldDataFromStorage () {
38+ String msg = "remove Old Data From Storage: " ;
39+ if (schedulerProperties .getRemoveOldDataFromStorageAllow () && !schedulerProperties .getSkipFortesting ()) {
40+ Task task = asyncStartTask .removeOldDataFromStorage ();
4141 log .info (msg + "SCHEDULED: task " +task .getUniqueId ());
4242 }
4343 }
4444
45- @ Scheduled (fixedRate = FIXED_RATE_FOR_SCHEDULAR_UPDATE_USER_BY_MENTION )
45+ @ Scheduled (initialDelay = TEN_SECONDS * 4 , fixedRate = FIXED_RATE_FOR_SCHEDULAR_UPDATE_USER_BY_MENTION )
4646 public void updateUserProfilesFromMentions (){
4747 String msg = "update User Profiles From Mentions" ;
4848 if (schedulerProperties .getAllowUpdateUserProfilesFromMention () && !schedulerProperties .getSkipFortesting ()) {
@@ -51,11 +51,20 @@ public void updateUserProfilesFromMentions(){
5151 }
5252 }
5353
54- @ Scheduled (fixedRate = FIXED_RATE_FOR_SCHEDULAR_FETCH_USER_LIST )
55- public void fetchUsersFromDefinedUserList (){
56- String msg = "fetch Users from Defined User List " ;
57- if (schedulerProperties .getFetchUserListAllow () && !schedulerProperties .getSkipFortesting ()) {
58- Task task = asyncStartTask .fetchUsersFromList ();
54+ @ Scheduled (initialDelay = TEN_SECONDS *5 , fixedRate = FIXED_RATE_FOR_SCHEDULAR_UPDATE_TWEETS )
55+ public void updateTweets () {
56+ String msg = "update Tweets " ;
57+ if (schedulerProperties .getAllowUpdateTweets () && !schedulerProperties .getSkipFortesting ()){
58+ Task task = asyncStartTask .updateTweets ();
59+ log .info (msg + "SCHEDULED: task " +task .getUniqueId ());
60+ }
61+ }
62+
63+ @ Scheduled (initialDelay = TEN_SECONDS *6 , fixedRate = FIXED_RATE_FOR_SCHEDULAR_UPDATE_USER )
64+ public void updateUserProfiles () {
65+ String msg = "update User Profiles " ;
66+ if (schedulerProperties .getAllowUpdateUserProfiles () && !schedulerProperties .getSkipFortesting ()) {
67+ Task task = asyncStartTask .updateUsers ();
5968 log .info (msg + "SCHEDULED: task " +task .getUniqueId ());
6069 }
6170 }
@@ -66,21 +75,25 @@ public ScheduledTasks(SchedulerProperties schedulerProperties, AsyncStartTask mq
6675 this .asyncStartTask = mqAsyncStartTask ;
6776 }
6877
69- public final static long EINE_MINUTE = 60 * 1000 ;
78+ public final static long TEN_SECONDS = 10 * 1000 ;
79+
80+ public final static long ONE_MINUTE = 60 * 1000 ;
81+
82+ public final static long ONE_HOUR = 60 * ONE_MINUTE ;
7083
71- public final static long EINE_STUNDE = 60 * EINE_MINUTE ;
84+ public final static long TWELVE_HOURS = 12 * ONE_HOUR ;
7285
73- public final static long ZWOELF_STUNDEN = 12 * EINE_STUNDE ;
86+ private final static long FIXED_RATE_FOR_SCHEDULAR_FETCH_TWEETS = ONE_HOUR ;
7487
75- private final static long FIXED_RATE_FOR_SCHEDULAR_FETCH_TWEETS = EINE_STUNDE ;
88+ private final static long FIXED_RATE_FOR_SCHEDULAR_UPDATE_USER = TWELVE_HOURS ;
7689
77- private final static long FIXED_RATE_FOR_SCHEDULAR_UPDATE_USER = ZWOELF_STUNDEN ;
90+ private final static long FIXED_RATE_FOR_SCHEDULAR_UPDATE_TWEETS = TWELVE_HOURS ;
7891
79- private final static long FIXED_RATE_FOR_SCHEDULAR_UPDATE_TWEETS = ZWOELF_STUNDEN ;
92+ private final static long FIXED_RATE_FOR_SCHEDULAR_UPDATE_USER_BY_MENTION = ONE_HOUR ;
8093
81- private final static long FIXED_RATE_FOR_SCHEDULAR_UPDATE_USER_BY_MENTION = EINE_STUNDE ;
94+ private final static long FIXED_RATE_FOR_SCHEDULAR_FETCH_USER_LIST = TWELVE_HOURS ;
8295
83- private final static long FIXED_RATE_FOR_SCHEDULAR_FETCH_USER_LIST = ZWOELF_STUNDEN ;
96+ private final static long FIXED_RATE_FOR_SCHEDULAR_REMOVE_OLD_DATA_FROM_STORAGE = ONE_HOUR ;
8497
8598 private static final Logger log = LoggerFactory .getLogger (ScheduledTasks .class );
8699
0 commit comments