You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@usergrid.apache.org by to...@apache.org on 2015/05/28 14:53:25 UTC
[20/50] [abbrv] incubator-usergrid git commit: Changed default wait
time to 10s
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/USERGRID-669
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) {