Repository: usergrid Updated Branches: refs/heads/master 20c17d4ff -> 949c2bbe0
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/master Commit: bfd2bb34aba3aeb5e296dfc88d950484e2a64972 Parents: d050300 Author: Michael Russo <[email protected]> Authored: Mon Feb 29 10:37:56 2016 -0800 Committer: Michael Russo <[email protected]> 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
