diff --git a/src/main/java/org/woehlke/twitterwall/scheduled/mq/endoint/impl/TweetFinisherImpl.java b/src/main/java/org/woehlke/twitterwall/scheduled/mq/endoint/impl/TweetFinisherImpl.java index e2f3690f..fe724bfb 100644 --- a/src/main/java/org/woehlke/twitterwall/scheduled/mq/endoint/impl/TweetFinisherImpl.java +++ b/src/main/java/org/woehlke/twitterwall/scheduled/mq/endoint/impl/TweetFinisherImpl.java @@ -40,14 +40,14 @@ public void finishAsnyc(Message> incomingMessageList) { if(incomingMessageList.getHeaders().containsKey("task_id")){ long taskId = (Long) incomingMessageList.getHeaders().get( "task_id"); Task task = taskService.findById(taskId); - String msgDone = "Sucessfully finished task "+task.getTaskType()+"via MQ by "+ SenderType.FIRE_AND_FORGET_SENDER; + String msgDone = "Sucessfully finished task "+task.getTaskType()+" via MQ by "+ SenderType.FIRE_AND_FORGET_SENDER; taskService.done(msgDone,task,countedEntities); log.info(msgDone); } else { if(userMessageList.size()>0) { long taskId = userMessageList.get(0).getTaskId(); Task task = taskService.findById(taskId); - String msgDone = "Sucessfully finished task "+task.getTaskType()+"via MQ by "+ SenderType.FIRE_AND_FORGET_SENDER; + String msgDone = "Sucessfully finished task "+task.getTaskType()+" via MQ by "+ SenderType.FIRE_AND_FORGET_SENDER; taskService.done(task,countedEntities); log.info(msgDone); } else { diff --git a/src/main/java/org/woehlke/twitterwall/scheduled/mq/endoint/impl/UserFinisherImpl.java b/src/main/java/org/woehlke/twitterwall/scheduled/mq/endoint/impl/UserFinisherImpl.java index 4c7bce3c..ad4018ad 100644 --- a/src/main/java/org/woehlke/twitterwall/scheduled/mq/endoint/impl/UserFinisherImpl.java +++ b/src/main/java/org/woehlke/twitterwall/scheduled/mq/endoint/impl/UserFinisherImpl.java @@ -44,14 +44,14 @@ public void finishAsnyc(Message> incomingMessageList) { if(incomingMessageList.getHeaders().containsKey("task_id")){ long taskId = (Long) incomingMessageList.getHeaders().get( "task_id"); Task task = taskService.findById(taskId); - String msgDone = "Sucessfully finished task "+task.getTaskType()+"via MQ by "+ SenderType.FIRE_AND_FORGET_SENDER; + String msgDone = "Sucessfully finished task "+task.getTaskType()+" via MQ by "+ SenderType.FIRE_AND_FORGET_SENDER; taskService.done(msgDone,task,countedEntities); log.info(msgDone); } else { if(userMessageList.size()>0) { long taskId = userMessageList.get(0).getTaskId(); Task task = taskService.findById(taskId); - String msgDone = "Sucessfully finished task "+task.getTaskType()+"via MQ by "+ SenderType.FIRE_AND_FORGET_SENDER; + String msgDone = "Sucessfully finished task "+task.getTaskType()+" via MQ by "+ SenderType.FIRE_AND_FORGET_SENDER; taskService.done(task,countedEntities); log.info(msgDone); } else {