working on #141 #142 #143

Author: phasenraum2010

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

@@ -51,7 +51,7 @@ public void fetchUsersFromDefinedUserList() {
     }
 
     private void send(TaskType taskType){
-        String msg = "START Task "+taskType+"via MQ by "+SenderType.FIRE_AND_FORGET_SENDER;
+        String msg = "START Task "+taskType+" via MQ by "+SenderType.FIRE_AND_FORGET_SENDER;
         log.info(msg);
         CountedEntities countedEntities = countedEntitiesService.countAll();
         Task task = taskService.create(msg, taskType,countedEntities);

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

@@ -79,12 +79,12 @@ public User createImprintUser() {
             UserMessage msg = (UserMessage) o;
             long taskId = msg.getTaskId();
             task = taskService.findById(taskId);
-            logMsg = "Sucessfully finished task "+taskType+"via MQ by "+ SenderType.SEND_AND_WAIT_FOR_RESULT_SENDER;
+            logMsg = "Sucessfully finished task "+taskType+" via MQ by "+ SenderType.SEND_AND_WAIT_FOR_RESULT_SENDER;
             taskService.done(logMsg, task, countedEntities);
             log.info(logMsg);
             return msg.getUser();
         } else {
-            logMsg = "Finished with Error: task "+taskType+"via MQ by "+ SenderType.SEND_AND_WAIT_FOR_RESULT_SENDER+": Wrong type of returnedMessage";
+            logMsg = "Finished with Error: task "+taskType+" via MQ by "+ SenderType.SEND_AND_WAIT_FOR_RESULT_SENDER+": Wrong type of returnedMessage";
             taskService.finalError(task,logMsg,countedEntities);
             log.error(logMsg);
             return null;
@@ -94,7 +94,7 @@ public User createImprintUser() {
     @Override
     public List<User> createTestDataForUser() {
         TaskType taskType = TaskType.CONTROLLER_GET_TESTDATA_USER;
-        String logMsg = "Start task "+taskType+"via MQ by "+ SenderType.SEND_AND_WAIT_FOR_RESULT_SENDER;
+        String logMsg = "Start task "+taskType+" via MQ by "+ SenderType.SEND_AND_WAIT_FOR_RESULT_SENDER;
         log.info(logMsg);
         CountedEntities countedEntities = countedEntitiesService.countAll();
         Task task = taskService.create("Start via MQ", taskType, countedEntities);
@@ -112,12 +112,12 @@ public List<User> createTestDataForUser() {
             UserResultList result = (UserResultList) o;
             long taskId = result.getTaskId();
             task = taskService.findById(taskId);
-            logMsg = "Sucessfully finished task "+taskType+"via MQ by "+ SenderType.SEND_AND_WAIT_FOR_RESULT_SENDER;
+            logMsg = "Sucessfully finished task "+taskType+" via MQ by "+ SenderType.SEND_AND_WAIT_FOR_RESULT_SENDER;
             taskService.done(logMsg, task, countedEntities);
             log.info(logMsg);
             return result.getUserList();
         } else {
-            logMsg = "Finished with Error: task "+taskType+"via MQ by "+ SenderType.SEND_AND_WAIT_FOR_RESULT_SENDER+": Wrong type of returnedMessage";
+            logMsg = "Finished with Error: task "+taskType+" via MQ by "+ SenderType.SEND_AND_WAIT_FOR_RESULT_SENDER+": Wrong type of returnedMessage";
             taskService.finalError(task,logMsg,countedEntities);
             log.error(logMsg);
             return new ArrayList<>();
@@ -127,7 +127,7 @@ public List<User> createTestDataForUser() {
     @Override
     public List<Tweet> createTestDataForTweets() {
         TaskType taskType = TaskType.CONTROLLER_GET_TESTDATA_TWEETS;
-        String logMsg = "Start task "+taskType+"via MQ by "+ SenderType.SEND_AND_WAIT_FOR_RESULT_SENDER;
+        String logMsg = "Start task "+taskType+" via MQ by "+ SenderType.SEND_AND_WAIT_FOR_RESULT_SENDER;
         log.info(logMsg);
         CountedEntities countedEntities = countedEntitiesService.countAll();
         Task task = taskService.create("Start via MQ by Scheduler ", taskType, countedEntities);
@@ -145,12 +145,12 @@ public List<Tweet> createTestDataForTweets() {
             TweetResultList result = (TweetResultList) o;
             long taskId = result.getTaskId();
             task = taskService.findById(taskId);
-            logMsg = "Sucessfully finished task "+taskType+"via MQ by "+ SenderType.SEND_AND_WAIT_FOR_RESULT_SENDER;
+            logMsg = "Sucessfully finished task "+taskType+" via MQ by "+ SenderType.SEND_AND_WAIT_FOR_RESULT_SENDER;
             taskService.done(logMsg, task, countedEntities);
             log.info(logMsg);
             return result.getTweetList();
         } else {
-            logMsg = "Finished with Error: task "+taskType+"via MQ by "+ SenderType.SEND_AND_WAIT_FOR_RESULT_SENDER+": Wrong type of returnedMessage";
+            logMsg = "Finished with Error: task "+taskType+" via MQ by "+ SenderType.SEND_AND_WAIT_FOR_RESULT_SENDER+": Wrong type of returnedMessage";
             taskService.finalError(task,logMsg,countedEntities);
             log.error(logMsg);
             return new ArrayList<>();