You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by mr...@apache.org on 2016/03/23 18:34:42 UTC
[14/20] usergrid git commit: Update variable reference for async
event creation time.
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 <mr...@apigee.com>
Authored: Mon Mar 21 11:40:21 2016 -0700
Committer: Michael Russo <mr...@apigee.com>
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());
}
});