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 <[email protected]> Authored: Fri Feb 19 23:10:40 2016 -0800 Committer: Michael Russo <[email protected]> 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()); }
