You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by sn...@apache.org on 2015/10/30 21:33:05 UTC
[41/50] [abbrv] usergrid git commit: fix for limit issue
fix for limit issue
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/ec726b6e
Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/ec726b6e
Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/ec726b6e
Branch: refs/heads/USERGRID-872
Commit: ec726b6eed30e5a34feeacfb95a25b56dcc54718
Parents: 4e647e0
Author: Shawn Feldman <sf...@apache.org>
Authored: Fri Oct 23 14:59:10 2015 -0600
Committer: Shawn Feldman <sf...@apache.org>
Committed: Fri Oct 23 14:59:10 2015 -0600
----------------------------------------------------------------------
.../org/apache/usergrid/corepersistence/CpEntityManager.java | 4 ++--
.../corepersistence/asyncevents/AmazonAsyncEventService.java | 2 +-
2 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/usergrid/blob/ec726b6e/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 4b32389..009266b 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
@@ -2897,7 +2897,7 @@ public class CpEntityManager implements EntityManager {
hasFinished = true;
break;
}
- Thread.sleep(200);
+ Thread.sleep(100);
indexRefreshCommandInfo
= managerCache.getEntityIndex(applicationScope).refreshAsync().toBlocking().first();
@@ -2908,7 +2908,7 @@ public class CpEntityManager implements EntityManager {
}finally {
delete(refreshEntity);
}
- Thread.sleep(200);
+ Thread.sleep(100);
return indexRefreshCommandInfo;
} catch (Exception e) {
http://git-wip-us.apache.org/repos/asf/usergrid/blob/ec726b6e/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 ef03bf8..14fbdaa 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
@@ -110,7 +110,7 @@ public class AmazonAsyncEventService implements AsyncEventService {
private static final Logger logger = LoggerFactory.getLogger(AmazonAsyncEventService.class);
// SQS maximum receive messages is 10
- public static int MAX_TAKE = 10;
+ public int MAX_TAKE = 10;
public static final String QUEUE_NAME = "index"; //keep this short as AWS limits queue name size to 80 chars
private final QueueManager queue;