You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by mr...@apache.org on 2016/02/25 20:56:53 UTC
[07/15] usergrid git commit: Add additional comments.
Add additional comments.
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/5dfbcca2
Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/5dfbcca2
Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/5dfbcca2
Branch: refs/heads/master
Commit: 5dfbcca2a60ae1463fb6f6e5a9a05225da4c2d85
Parents: 3c399e7
Author: Michael Russo <mi...@gmail.com>
Authored: Fri Feb 19 23:10:40 2016 -0800
Committer: Michael Russo <mi...@gmail.com>
Committed: Fri Feb 19 23:10:40 2016 -0800
----------------------------------------------------------------------
.../corepersistence/asyncevents/AsyncEventServiceImpl.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/usergrid/blob/5dfbcca2/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventServiceImpl.java
----------------------------------------------------------------------
diff --git a/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventServiceImpl.java b/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventServiceImpl.java
index dac3651..7a71410 100644
--- a/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventServiceImpl.java
+++ b/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventServiceImpl.java
@@ -340,7 +340,8 @@ public class AsyncEventServiceImpl implements AsyncEventService {
}
- //return type that can be indexed and ack'd later
+ // returning indexOperationMessage will send that indexOperationMessage to the index producer
+ // if no exception happens and the QueueMessage is returned in these results, it will get ack'd
return new IndexEventResult(Optional.fromNullable(indexOperationMessage), Optional.of(message), thisEvent.getCreationTime());
} catch (IndexDocNotFoundException e){
@@ -352,7 +353,7 @@ public class AsyncEventServiceImpl implements AsyncEventService {
} catch (Exception e) {
- // if the event fails to process, log the message and return empty event result so it doesn't get ack'd
+ // if the event fails to process, log and return empty message result so it doesn't get ack'd
logger.error("Failed to process message: {} {}", message.getMessageId(), message.getStringBody(), e);
return new IndexEventResult(Optional.absent(), Optional.absent(), event.getCreationTime());
}