Skip to content

Commit 8a84241

Browse files
Merge pull request #150 from phasenraum2010/milestone-1.0.16
Milestone 1.0.16
2 parents 63f4688 + 9ab735a commit 8a84241

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -40,14 +40,14 @@ public void finishAsnyc(Message<List<TweetFromTwitter>> incomingMessageList) {
4040
if(incomingMessageList.getHeaders().containsKey("task_id")){
4141
long taskId = (Long) incomingMessageList.getHeaders().get( "task_id");
4242
Task task = taskService.findById(taskId);
43-
String msgDone = "Sucessfully finished task "+task.getTaskType()+"via MQ by "+ SenderType.FIRE_AND_FORGET_SENDER;
43+
String msgDone = "Sucessfully finished task "+task.getTaskType()+" via MQ by "+ SenderType.FIRE_AND_FORGET_SENDER;
4444
taskService.done(msgDone,task,countedEntities);
4545
log.info(msgDone);
4646
} else {
4747
if(userMessageList.size()>0) {
4848
long taskId = userMessageList.get(0).getTaskId();
4949
Task task = taskService.findById(taskId);
50-
String msgDone = "Sucessfully finished task "+task.getTaskType()+"via MQ by "+ SenderType.FIRE_AND_FORGET_SENDER;
50+
String msgDone = "Sucessfully finished task "+task.getTaskType()+" via MQ by "+ SenderType.FIRE_AND_FORGET_SENDER;
5151
taskService.done(task,countedEntities);
5252
log.info(msgDone);
5353
} else {

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -44,14 +44,14 @@ public void finishAsnyc(Message<List<UserMessage>> incomingMessageList) {
4444
if(incomingMessageList.getHeaders().containsKey("task_id")){
4545
long taskId = (Long) incomingMessageList.getHeaders().get( "task_id");
4646
Task task = taskService.findById(taskId);
47-
String msgDone = "Sucessfully finished task "+task.getTaskType()+"via MQ by "+ SenderType.FIRE_AND_FORGET_SENDER;
47+
String msgDone = "Sucessfully finished task "+task.getTaskType()+" via MQ by "+ SenderType.FIRE_AND_FORGET_SENDER;
4848
taskService.done(msgDone,task,countedEntities);
4949
log.info(msgDone);
5050
} else {
5151
if(userMessageList.size()>0) {
5252
long taskId = userMessageList.get(0).getTaskId();
5353
Task task = taskService.findById(taskId);
54-
String msgDone = "Sucessfully finished task "+task.getTaskType()+"via MQ by "+ SenderType.FIRE_AND_FORGET_SENDER;
54+
String msgDone = "Sucessfully finished task "+task.getTaskType()+" via MQ by "+ SenderType.FIRE_AND_FORGET_SENDER;
5555
taskService.done(task,countedEntities);
5656
log.info(msgDone);
5757
} else {

0 commit comments

Comments
 (0)