Updating EdgeDeleteEvent
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/f24e7e40 Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/f24e7e40 Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/f24e7e40 Branch: refs/heads/USERGRID-933 Commit: f24e7e40cbd4f55154f4585d795a793d870c528f Parents: 66ba6b4 Author: Michael Russo <michaelaru...@gmail.com> Authored: Fri Sep 11 13:35:51 2015 -0700 Committer: Michael Russo <michaelaru...@gmail.com> Committed: Fri Sep 11 13:35:51 2015 -0700 ---------------------------------------------------------------------- .../corepersistence/asyncevents/AmazonAsyncEventService.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/usergrid/blob/f24e7e40/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 71834c3..fcb93c9 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 @@ -354,10 +354,10 @@ public class AmazonAsyncEventService implements AsyncEventService { Preconditions.checkArgument(event instanceof EdgeDeleteEvent, String.format("Event Type for handleEdgeDelete must be EDGE_DELETE, got %s", event.getClass())); - final EdgeIndexEvent edgeIndexEvent = ( EdgeIndexEvent ) event; + final EdgeDeleteEvent edgeDeleteEvent = ( EdgeDeleteEvent ) event; - final ApplicationScope applicationScope = edgeIndexEvent.getApplicationScope(); - final Edge edge = edgeIndexEvent.getEdge(); + final ApplicationScope applicationScope = edgeDeleteEvent.getApplicationScope(); + final Edge edge = edgeDeleteEvent.getEdge(); if (logger.isDebugEnabled()) logger.debug("Deleting in app scope {} with edge {}", applicationScope, edge);
