fixed #240

Author: phasenraum2010

src/main/java/org/woehlke/twitterwall/ScheduledTasks.java

@@ -42,8 +42,16 @@ public void fetchFollower(){
         }
     }
 
+    @Scheduled(initialDelay= TEN_SECONDS *4, fixedRate = FIXED_RATE_FOR_SCHEDULAR_FETCH_FRIENDS)
+    public void fetchFriends(){
+        String msg = "fetch Friends ";
+        if(schedulerProperties.getFetchFriendsAllow() && !schedulerProperties.getSkipFortesting()) {
+            Task task = asyncStartTask.fetchFriends();
+            log.info(msg+ "SCHEDULED: task "+task.getUniqueId());
+        }
+    }
 
-    @Scheduled(initialDelay= TEN_SECONDS *4, fixedRate = FIXED_RATE_FOR_SCHEDULAR_REMOVE_OLD_DATA_FROM_STORAGE)
+    @Scheduled(initialDelay= TEN_SECONDS *5, fixedRate = FIXED_RATE_FOR_SCHEDULAR_REMOVE_OLD_DATA_FROM_STORAGE)
     public void removeOldDataFromStorage(){
         String msg = "remove Old Data From Storage: ";
         if(schedulerProperties.getRemoveOldDataFromStorageAllow()  && !schedulerProperties.getSkipFortesting()) {
@@ -52,7 +60,7 @@ public void removeOldDataFromStorage(){
         }
     }
 
-    @Scheduled(initialDelay= TEN_SECONDS *5, fixedRate = FIXED_RATE_FOR_SCHEDULAR_UPDATE_USER_BY_MENTION)
+    @Scheduled(initialDelay= TEN_SECONDS *6, fixedRate = FIXED_RATE_FOR_SCHEDULAR_UPDATE_USER_BY_MENTION)
     public void updateUserProfilesFromMentions(){
         String msg = "update User Profiles From Mentions";
         if(schedulerProperties.getAllowUpdateUserProfilesFromMention() && !schedulerProperties.getSkipFortesting()) {
@@ -61,7 +69,7 @@ public void updateUserProfilesFromMentions(){
         }
     }
 
-    @Scheduled(initialDelay= TEN_SECONDS *6, fixedRate = FIXED_RATE_FOR_SCHEDULAR_UPDATE_TWEETS)
+    @Scheduled(initialDelay= TEN_SECONDS *7, fixedRate = FIXED_RATE_FOR_SCHEDULAR_UPDATE_TWEETS)
     public void updateTweets() {
         String msg = "update Tweets ";
         if(schedulerProperties.getAllowUpdateTweets() && !schedulerProperties.getSkipFortesting()){
@@ -70,7 +78,7 @@ public void updateTweets() {
         }
     }
 
-    @Scheduled(initialDelay= TEN_SECONDS *7, fixedRate = FIXED_RATE_FOR_SCHEDULAR_UPDATE_USER)
+    @Scheduled(initialDelay= TEN_SECONDS *8, fixedRate = FIXED_RATE_FOR_SCHEDULAR_UPDATE_USER)
     public void updateUserProfiles() {
         String msg = "update User Profiles ";
         if(schedulerProperties.getAllowUpdateUserProfiles()  && !schedulerProperties.getSkipFortesting()) {
@@ -79,15 +87,6 @@ public void updateUserProfiles() {
         }
     }
 
-    @Scheduled(initialDelay= TEN_SECONDS *8, fixedRate = FIXED_RATE_FOR_SCHEDULAR_FETCH_FRIENDS)
-    public void fetchFriends(){
-        String msg = "fetch Friends ";
-        if(schedulerProperties.getFetchFriendsAllow() && !schedulerProperties.getSkipFortesting()) {
-            Task task = asyncStartTask.fetchFriends();
-            log.info(msg+ "SCHEDULED: task "+task.getUniqueId());
-        }
-    }
-
     @Autowired
     public ScheduledTasks(SchedulerProperties schedulerProperties, AsyncStartTask mqAsyncStartTask) {
         this.schedulerProperties = schedulerProperties;

src/main/java/org/woehlke/twitterwall/oodm/service/impl/DomainServiceWithTaskImpl.java

@@ -60,8 +60,8 @@ public T store(T domainObject, Task task) {
                     } else {
                         domainObjectPersistent = null;
                         log.error(msg+"Something strange happened!");
-                        log.debug(msg+"tried to persist: " + domainObject.toString());
-                        log.debug(msg+"found: " + domainObjectPersistent.toString());
+                        log.debug(msg+"tried to persist: " + domainObject.getUniqueId());
+                        log.debug(msg+"found: " + domainObjectPersistent.getUniqueId());
                     }
                 }
             }
@@ -79,13 +79,13 @@ public T store(T domainObject, Task task) {
             } else {
                 domainObject.setCreatedBy(task);
                 domainObject.setUpdatedBy(task);
-                log.debug("try to persist: " + domainObject.toString());
+                log.debug("try to persist: " + domainObject.getUniqueId());
                 storedObject = domainRepository.save(domainObject);
                 domainObjectResult = storedObject;
-                log.debug("persisted: " + domainObjectResult.toString());
+                log.debug("persisted: " + domainObjectResult.getUniqueId());
             }
         } catch (Exception e)  {
-            log.warn(msg,e.getMessage());
+            log.warn(msg+domainObject.toString(),e);
         }
         return domainObjectResult;
     }