Adds comment
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/4013f17e Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/4013f17e Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/4013f17e Branch: refs/heads/usergrid-1007-shiro-cache Commit: 4013f17e434a5eb05f4851d28dba6a3e0bfe8fc8 Parents: 19d30ea Author: Todd Nine <tn...@apigee.com> Authored: Mon Oct 19 14:10:51 2015 -0600 Committer: Todd Nine <tn...@apigee.com> Committed: Mon Oct 19 14:10:51 2015 -0600 ---------------------------------------------------------------------- .../corepersistence/asyncevents/AmazonAsyncEventService.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/4013f17e/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AmazonAsyncEventService.java ---------------------------------------------------------------------- diff --git a/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AmazonAsyncEventService.java b/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AmazonAsyncEventService.java index 67d0dab..ee9054b 100644 --- a/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AmazonAsyncEventService.java +++ b/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AmazonAsyncEventService.java @@ -536,6 +536,10 @@ public class AmazonAsyncEventService implements AsyncEventService { indexOperationMessage = ObjectJsonSerializer.INSTANCE.fromString( message, IndexOperationMessage.class ); } + + //NOTE that we intentionally do NOT delete from the map. We can't know when all regions have consumed the message + //so we'll let compaction on column expiration handle deletion + //read the value from the string Preconditions.checkNotNull( indexOperationMessage, "indexOperationMessage cannot be null" );
