Repository: incubator-usergrid Updated Branches: refs/heads/USERGRID-614 [created] 36b5bad2d
Added queueing of delete operation Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/36b5bad2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/36b5bad2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/36b5bad2 Branch: refs/heads/USERGRID-614 Commit: 36b5bad2d6efb0b2155e0a0be257b15e56d40ba1 Parents: 5c5aa8c Author: Todd Nine <[email protected]> Authored: Tue May 5 09:56:06 2015 -0600 Committer: Todd Nine <[email protected]> Committed: Tue May 5 09:56:06 2015 -0600 ---------------------------------------------------------------------- .../org/apache/usergrid/corepersistence/CpEntityManager.java | 4 ++++ .../test/java/org/apache/usergrid/persistence/CollectionIT.java | 4 ++-- 2 files changed, 6 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/36b5bad2/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 7d003cc..460fc11 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 @@ -660,6 +660,10 @@ public class CpEntityManager implements EntityManager { decrementEntityCollection( Schema.defaultCollectionName( entityId.getType() ) ); // and finally... + + //delete it asynchronously + indexService.queueEntityDelete( applicationScope, entityId ); + return ecm.delete( entityId ); } else { http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/36b5bad2/stack/core/src/test/java/org/apache/usergrid/persistence/CollectionIT.java ---------------------------------------------------------------------- diff --git a/stack/core/src/test/java/org/apache/usergrid/persistence/CollectionIT.java b/stack/core/src/test/java/org/apache/usergrid/persistence/CollectionIT.java index 8c94d32..9abfac9 100644 --- a/stack/core/src/test/java/org/apache/usergrid/persistence/CollectionIT.java +++ b/stack/core/src/test/java/org/apache/usergrid/persistence/CollectionIT.java @@ -363,7 +363,7 @@ public class CollectionIT extends AbstractCoreIT { app.refreshIndex(); -// Thread.sleep(500); + Thread.sleep(1000); //TODO find why we have to wait. This is a bug final Query query = Query.fromQL( "nickname = 'ed'" ); @@ -966,7 +966,7 @@ public class CollectionIT extends AbstractCoreIT { app.refreshIndex(); // wait for indexes to be cleared - Thread.sleep( 500 ); + Thread.sleep(1000); //TODO find why we have to wait. This is a bug // now query with paging query = new Query();
