Update variable reference for async event creation time.
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/aef26b9b Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/aef26b9b Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/aef26b9b Branch: refs/heads/release-2.1.1 Commit: aef26b9bc0d3af7131aec16b49fe27f4af081e41 Parents: 4d828e1 Author: Michael Russo <[email protected]> Authored: Mon Mar 21 11:40:21 2016 -0700 Committer: Michael Russo <[email protected]> Committed: Mon Mar 21 11:40:21 2016 -0700 ---------------------------------------------------------------------- .../corepersistence/asyncevents/AsyncEventServiceImpl.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/aef26b9b/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 cc1246f..1b32b48 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 @@ -354,13 +354,13 @@ public class AsyncEventServiceImpl implements AsyncEventService { if(logger.isDebugEnabled()){ logger.debug(e.getMessage()); } - return new IndexEventResult(Optional.absent(), Optional.absent(), event.getCreationTime()); + return new IndexEventResult(Optional.absent(), Optional.absent(), thisEvent.getCreationTime()); } catch (Exception e) { // 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: {}", e.getMessage(), message.getStringBody().trim() ); - return new IndexEventResult(Optional.absent(), Optional.absent(), event.getCreationTime()); + return new IndexEventResult(Optional.absent(), Optional.absent(), thisEvent.getCreationTime()); } });
