You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by mr...@apache.org on 2016/02/29 19:38:00 UTC
usergrid git commit: Always set a minimum of 1 second for the SQS
long polling.
Repository: usergrid
Updated Branches:
refs/heads/release-2.1.1 d050300d5 -> bfd2bb34a
Always set a minimum of 1 second for the SQS long polling.
Project: http://git-wip-us.apache.org/repos/asf/usergrid/repo
Commit: http://git-wip-us.apache.org/repos/asf/usergrid/commit/bfd2bb34
Tree: http://git-wip-us.apache.org/repos/asf/usergrid/tree/bfd2bb34
Diff: http://git-wip-us.apache.org/repos/asf/usergrid/diff/bfd2bb34
Branch: refs/heads/release-2.1.1
Commit: bfd2bb34aba3aeb5e296dfc88d950484e2a64972
Parents: d050300
Author: Michael Russo <mr...@apigee.com>
Authored: Mon Feb 29 10:37:56 2016 -0800
Committer: Michael Russo <mr...@apigee.com>
Committed: Mon Feb 29 10:37:56 2016 -0800
----------------------------------------------------------------------
.../corepersistence/asyncevents/AsyncEventServiceImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/usergrid/blob/bfd2bb34/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventServiceImpl.java
----------------------------------------------------------------------
diff --git a/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventServiceImpl.java b/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventServiceImpl.java
index d3b87ad..782bed7 100644
--- a/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventServiceImpl.java
+++ b/stack/core/src/main/java/org/apache/usergrid/corepersistence/asyncevents/AsyncEventServiceImpl.java
@@ -244,7 +244,7 @@ public class AsyncEventServiceImpl implements AsyncEventService {
try {
return queue.getMessages(MAX_TAKE,
indexProcessorFig.getIndexQueueVisibilityTimeout(),
- queueFig.getQueueClientSocketTimeout() - 1000, // 1 second less than socket timeout
+ Math.max(1000, queueFig.getQueueClientSocketTimeout() - 1000), // 1 sec less than socket timeout
AsyncEvent.class);
}
//stop our timer