usergrid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mru...@apache.org
Subject [07/15] usergrid git commit: Add additional comments.
Date Thu, 25 Feb 2016 19:56:53 GMT
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 <michaelarusso@gmail.com>
Authored: Fri Feb 19 23:10:40 2016 -0800
Committer: Michael Russo <michaelarusso@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());
             }


Mime
View raw message