Repository: usergrid Updated Branches: refs/heads/USERGRID-1048 e50835f10 -> 4889ce217
Fixes incorrect units on timeout from millis to seconds. Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/4889ce21 Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/4889ce21 Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/4889ce21 Branch: refs/heads/USERGRID-1048 Commit: 4889ce2179a7632a43f77bb684c280161f4d1a2e Parents: e50835f Author: Todd Nine <[email protected]> Authored: Tue Oct 20 11:37:03 2015 -0600 Committer: Todd Nine <[email protected]> Committed: Tue Oct 20 11:37:03 2015 -0600 ---------------------------------------------------------------------- .../corepersistence/asyncevents/AmazonAsyncEventService.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/4889ce21/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 6f779b5..ca1402f 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 @@ -491,8 +491,10 @@ public class AmazonAsyncEventService implements AsyncEventService { final UUID newMessageId = UUIDGenerator.newTimeUUID(); + final int expirationTimeInSeconds = indexProcessorFig.getIndexMessageTtl()/1000; + //write to the map in ES - esMapPersistence.putString( newMessageId.toString(), jsonValue, indexProcessorFig.getIndexMessageTtl() ); + esMapPersistence.putString( newMessageId.toString(), jsonValue, expirationTimeInSeconds );
