From 9ab735ac99c2df48ec19e7be0d963d745511b80e Mon Sep 17 00:00:00 2001 From: phasenraum2010 Date: Tue, 25 Jul 2017 17:19:36 +0200 Subject: [PATCH] bugfix --- .../scheduled/mq/endoint/impl/TweetFinisherImpl.java | 4 ++-- .../scheduled/mq/endoint/impl/UserFinisherImpl.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) 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 {