You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by sf...@apache.org on 2014/10/07 21:27:32 UTC
[16/17] git commit: Adding EntityDeletedImpl
Adding EntityDeletedImpl
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/6446cd64
Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/6446cd64
Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/6446cd64
Branch: refs/heads/two-dot-o-events
Commit: 6446cd64d086608013006c2694d0b35c61e0ebd4
Parents: 0af27bd
Author: Shawn Feldman <sf...@apache.org>
Authored: Tue Oct 7 13:25:47 2014 -0600
Committer: Shawn Feldman <sf...@apache.org>
Committed: Tue Oct 7 13:25:47 2014 -0600
----------------------------------------------------------------------
.../usergrid/corepersistence/CpEntityManager.java | 4 ++--
.../collection/event/impl/EntityDeletedImpl.java | 16 ++++++++++++++++
2 files changed, 18 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/6446cd64/stack/core/src/main/java/org/apache/usergrid/corepersistence/CpEntityManager.java
----------------------------------------------------------------------
diff --git a/stack/core/src/main/java/org/apache/usergrid/corepersistence/CpEntityManager.java b/stack/core/src/main/java/org/apache/usergrid/corepersistence/CpEntityManager.java
index 1a8f17c..0ee5ef9 100644
--- a/stack/core/src/main/java/org/apache/usergrid/corepersistence/CpEntityManager.java
+++ b/stack/core/src/main/java/org/apache/usergrid/corepersistence/CpEntityManager.java
@@ -522,7 +522,7 @@ public class CpEntityManager implements EntityManager {
@Override
public void delete( EntityRef entityRef ) throws Exception {
- deleteAsync( entityRef ).toBlockingObservable().lastOrDefault(null);
+ deleteAsync( entityRef ).toBlocking().lastOrDefault(null);
}
@@ -543,7 +543,7 @@ public class CpEntityManager implements EntityManager {
// }
org.apache.usergrid.persistence.model.entity.Entity entity =
- ecm.load( entityId ).toBlockingObservable().last();
+ ecm.load( entityId ).toBlocking().last();
if ( entity != null ) {
http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/6446cd64/stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/event/impl/EntityDeletedImpl.java
----------------------------------------------------------------------
diff --git a/stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/event/impl/EntityDeletedImpl.java b/stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/event/impl/EntityDeletedImpl.java
new file mode 100644
index 0000000..b056e63
--- /dev/null
+++ b/stack/corepersistence/collection/src/main/java/org/apache/usergrid/persistence/collection/event/impl/EntityDeletedImpl.java
@@ -0,0 +1,16 @@
+package org.apache.usergrid.persistence.collection.event.impl;
+
+import org.apache.usergrid.persistence.collection.CollectionScope;
+import org.apache.usergrid.persistence.collection.event.EntityDeleted;
+import org.apache.usergrid.persistence.model.entity.Id;
+
+
+public class EntityDeletedImpl implements EntityDeleted {
+
+ public EntityDeletedImpl(){}
+
+ @Override
+ public void deleted(CollectionScope scope, Id entityId) {
+
+ }
+}