Changed default wait time to 10s
Project: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/commit/b4d8be67 Tree: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/tree/b4d8be67 Diff: http://git-wip-us.apache.org/repos/asf/incubator-usergrid/diff/b4d8be67 Branch: refs/heads/two-dot-o-dev Commit: b4d8be677fcf651845bfcdc41f153f41eb645639 Parents: e27d9f0 Author: Jeff West <jw...@apigee.com> Authored: Tue May 26 09:04:53 2015 -0700 Committer: Jeff West <jw...@apigee.com> Committed: Tue May 26 09:04:53 2015 -0700 ---------------------------------------------------------------------- .../org/apache/usergrid/services/notifications/QueueListener.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-usergrid/blob/b4d8be67/stack/services/src/main/java/org/apache/usergrid/services/notifications/QueueListener.java ---------------------------------------------------------------------- diff --git a/stack/services/src/main/java/org/apache/usergrid/services/notifications/QueueListener.java b/stack/services/src/main/java/org/apache/usergrid/services/notifications/QueueListener.java index e45b82a..e9f64b4 100644 --- a/stack/services/src/main/java/org/apache/usergrid/services/notifications/QueueListener.java +++ b/stack/services/src/main/java/org/apache/usergrid/services/notifications/QueueListener.java @@ -156,7 +156,7 @@ public class QueueListener { try { Timer.Context timerContext = timer.time(); - List<QueueMessage> messages = queueManager.getMessages(getBatchSize(), MESSAGE_TRANSACTION_TIMEOUT, 5000, ApplicationQueueMessage.class); + List<QueueMessage> messages = queueManager.getMessages(getBatchSize(), MESSAGE_TRANSACTION_TIMEOUT, 10000, ApplicationQueueMessage.class); LOG.info("retrieved batch of {} messages from queue {} ", messages.size(),queueName); if (messages.size() > 0) {
