Merge branch 'two-dot-o-dev' of https://git-wip-us.apache.org/repos/asf/incubator-usergrid into two-dot-o-dev
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/a0d9a617 Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/a0d9a617 Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/a0d9a617 Branch: refs/heads/USERGRID-628 Commit: a0d9a6174cdeb2b76cdd58df55fb06826c4e4ee3 Parents: 4b81254 758c0e5 Author: Dave Johnson <dmjohn...@apigee.com> Authored: Thu May 28 07:53:08 2015 -0400 Committer: Dave Johnson <dmjohn...@apigee.com> Committed: Thu May 28 07:53:08 2015 -0400 ---------------------------------------------------------------------- .../corepersistence/CpEntityManagerFactory.java | 11 +- .../asyncevents/AmazonAsyncEventService.java | 426 +++++++++++++++++++ .../asyncevents/AsyncIndexProvider.java | 38 +- .../asyncevents/SQSAsyncEventService.java | 356 ---------------- .../asyncevents/model/AsyncEvent.java | 117 +++++ .../asyncevents/model/EdgeDeleteEvent.java | 45 ++ .../asyncevents/model/EdgeIndexEvent.java | 46 ++ .../asyncevents/model/EntityDeleteEvent.java | 36 ++ .../asyncevents/model/EntityIndexEvent.java | 39 ++ .../index/IndexProcessorFig.java | 13 +- .../corepersistence/StaleIndexCleanupTest.java | 8 +- .../index/AmazonAsyncEventServiceTest.java | 84 ++++ .../index/SQSAsyncEventServiceTest.java | 84 ---- .../cassandra/EntityManagerFactoryImplIT.java | 40 +- stack/corepersistence/pom.xml | 2 +- .../usergrid/persistence/queue/QueueFig.java | 19 + .../persistence/queue/guice/QueueModule.java | 12 +- .../queue/impl/SNSQueueManagerImpl.java | 370 ++++++++++++++++ .../queue/impl/SQSQueueManagerImpl.java | 239 +++++++---- .../queue/util/AmazonNotificationUtils.java | 177 ++++++++ .../exceptions/AbstractExceptionMapper.java | 9 + .../services/notifications/QueueListener.java | 2 +- 22 files changed, 1585 insertions(+), 588 deletions(-) ----------------------------------------------------------------------
